v(フィールド名)
パラメータ名 | パラメータ説明 | パラメータタイプ | 必須かどうか | パラメータのデフォルト値 | パラメータの値の範囲 |
field | フィールド名 | string | はい | - | - |
{"message": "failed", "status": "500"}
fields_set("new_message", v("message"))
{"message": "failed", "new_message": "failed","status": "500"}
fields_drop(フィールド名1, フィールド名2, ..., regex=False,nest=False)
パラメータ名 | パラメータ説明 | パラメータタイプ | 必須かどうか | パラメータのデフォルト値 | パラメータの値の範囲 |
可変引数、フィールド名またはフィールド名の正規表現 | 可変引数、フィールド名またはフィールド名の正規表現 | string | はい | - | - |
regex | 正規表現を有効にするかどうか、マッチングモードは完全一致です。 | bool | いいえ | False | - |
nest | ネストされたフィールドかどうか | bool | いいえ | False | - |
{"field": "a,b,c", "status": "500"}
fields_drop("field")
{"status":"500"}
{"condition":"{\\"a\\":\\"aaa\\", \\"c\\":\\"ccc\\", \\"e\\":\\"eee\\"}","status":"500"}
//nest=True、このフィールドはネストされたフィールドであることを示します。condition.aとcondition.cを破棄した後、condition.eフィールドのみが残ります。t_if(if_json(v("condition")), fields_drop("condition.a", "condition.c", nest=True))
{"condition":"{\\"e\\":\\"eee\\"}","status":"500"}
{"App": "thcomm","Message": "{\\"f_httpstatus\\": \\"200\\",\\"f_requestId\\": \\"2021-11-09 08:40:17.832\\tINFO\\tservices/http_service.go:361\\tbb20ac02-fcbc-4a56-b1f1-4064853b79da\\",\\"f_url\\": \\"wechat.wecity.qq.com/trpcapi/MbpsPaymentServer/scanCode\\"}"}
//nest=True、このフィールドはネストされたフィールドであることを示します。Message.f_requestId", Message.f_urlを破棄した後、f_httpstatusフィールドのみが残ります。t_if(if_json(v("Message")), fields_drop("Message.f_requestId", "Message.f_url", nest=True))
{"App":"thcomm","Message":"{\\"f_httpstatus\\":\\"200\\"}"}
fields_keep(フィールド名1, フィールド名2, ..., regex=False)
パラメータ名 | パラメータ説明 | パラメータタイプ | 必須かどうか | パラメータのデフォルト値 | パラメータの値の範囲 |
可変引数、フィールド名またはフィールド名の正規表現 | 可変引数、フィールド名またはフィールド名の正規表現 | string | はい | - | - |
regex | 正規表現を有効にするかどうか、マッチングモードは完全一致です。 | bool | いいえ | False | - |
{"field": "a,b,c", "status": "500"}
fields_keep("field")
{"field":"a,b,c"}
fields_pack(対象フィールド名, include=".*", exclude="", drop_packed=False)
パラメータ名 | パラメータ説明 | パラメータタイプ | 必須かどうか | パラメータのデフォルト値 | パラメータの値の範囲 |
output | パッケージ化後の新しいフィールド名 | string | はい | - | - |
include | フィールド名を含む正規表現 | string | いいえ | - | - |
exclude | 除外するフィールド名の正規表現 | string | いいえ | - | - |
drop_packed | 元のパッケージ化されたフィールドを削除するかどうか | bool | いいえ | False | - |
{"field_a": "a,b,c","field_b": "abc", "status": "500"}
fields_pack("new_field","field.*", drop_packed=False)
{"new_field":"{\\"field_a\\":\\"a,b,c\\",\\"field_b\\":\\"abc\\"}","field_a":"a,b,c","field_b":"abc","status":"500"}
fields_set(フィールド名1, フィールド値1, フィールド名2, フィールド値2, mode="overwrite")
パラメータ名 | パラメータ説明 | パラメータタイプ | 必須かどうか | パラメータのデフォルト値 | パラメータの値の範囲 |
可変引数 | key、valueが交互に並ぶパラメータリスト | string | - | - | - |
mode | フィールド上書きモード | string | いいえ | overwrite |
{"级别": "Info"}
fields_set("级别", "Warning")
{"级别":"Warning"}
{"a": "1", "b": "2", "c": "3"}
fields_set("new", v("b"), "new2", v("c"))
{"a":"1","b":"2","c":"3","new":"2","new2":"3"}
fields_rename(フィールド名1, 新フィールド名1, フィールド名2, 新フィールド名2, regex=False)
パラメータ名 | パラメータ説明 | パラメータタイプ | 必須かどうか | パラメータのデフォルト値 | パラメータの値の範囲 |
可変引数 | 旧フィールド名、新フィールド名が交互に並ぶパラメータリスト | string | - | - | - |
regex | フィールド名で正規表現マッチングを有効にするかどうかです。有効にすると正規表現で旧フィールド名をマッチングし、無効にすると等価マッチングを行います。 | bool | いいえ | False | - |
{"regieeen": "bj", "status": "500"}
fields_rename("reg.*", "region", regex=True)
{"region":"bj","status":"500"}
has_field(フィールド名)
パラメータ名 | パラメータ説明 | パラメータタイプ | 必須かどうか | パラメータのデフォルト値 | パラメータの値の範囲 |
field | フィールド名 | string | はい | - | - |
{"regiooon": "bj", "status": "500"}
t_if(has_field("regiooon"), fields_rename("regiooon", "region"))
{"region":"bj","status":"500"}
not_has_field(フィールド名)
パラメータ名 | パラメータ説明 | パラメータタイプ | 必須かどうか | パラメータのデフォルト値 | パラメータの値の範囲 |
field | フィールド名 | string | はい | - | - |
{"status": "500"}
t_if(not_has_field("message"), fields_set("no_message", true))
{"no_message":"true","status":"500"}
log_auto_output(v("pd"),"我的日志集",index_options="content_index", period=3,tag_static="Ckafka:test_env,developer:MikeWang",tag_dynamic=extract_tag("pd",v("pd"),"team", v("team")))は、tag_static静的Tagとtag_dynamic動的Tagを使用しています。extract_tag(タグ名1、タグ値1、タグ名2、タグ値2....)
パラメータ名 | パラメータ説明 | パラメータタイプ | 必須かどうか | パラメータのデフォルト値 | パラメータの値の範囲 |
Tag名 | Tag名 | string | はい | - | - |
Tag値 | Tag値 | string | はい | - | - |
[{"pd": "CDN", "team": "test"},{"pd": "CLS", "team": "product"},{"pd": "COS", "team": "sales"},{"pd": "CLS", "team": "test"},{"pd": "CKafka", "team": "product"}]
log_auto_output(v("pd"),"我的日志集",index_options="content_index", period=3,tag_static="Ckafka:test_env",tag_dynamic=extract_tag("pd",v("pd"),"team", v("team")))
フィードバック