tencent cloud

Cloud Log Service

ログの構造化 - Grok

ダウンロード
フォーカスモード
フォントサイズ
最終更新日: 2026-10-12 14:51:41
AI翻訳

シナリオ説明

小王はKafkaプロトコルによるログアップロードを通じて、Beatsが収集したログをCLSに報告します。手順は以下の通りです:
1. grok関数を使用してログを構造化します。
2. 日志内のtimeフィールドを使用して、CLSのログ時間(__TIMESTAMP__)を置き換えてください。




元のログ


{
"__FILENAME__": "",
"__SOURCE__": "192.168.100.123",
"message": "2024-10-11 15:32:10.003 DEBUG [gateway,746db87efd1bbcf5434cb9835c59e522,47c3036810e0c33b] [scheduled-Thread-1] c.i.g.c.f.d.a.task.AppleHealthCheckTask"
}

加工結果

{
"__FILENAME__":"",
"__SOURCE__":"192.168.100.123",
"__TIMESTAMP__":"1728631930003",
"level":"DEBUG",
"service":"gateway",
"spanid":"47c3036810e0c33b",
"time":"2024-10-11 15:32:10.003",
"traceid":"746db87efd1bbcf5434cb9835c59e522"
}

加工ステートメント

//grok関数を使用してログから時間time、ログレベルlevel、service、traceid、spanidを抽出します。
ext_grok("message",grok="%{TIMESTAMP_ISO8601:time} %{DATA:level} \\[%{DATA:service},%{DATA:traceid},%{DATA:spanid}\\]")
//messageフィールドを削除します。
fields_drop("message")
// custom_cls_log_time関数は、新しいフィールドtimeを使用してCLSのログ時間(__TIMESTAMP__)を置き換えます。
custom_cls_log_time(dt_to_timestamp(v("time"), zone="UTC+8"))


ヘルプとサポート

この記事はお役に立ちましたか?

フィードバック