signal_type 可取 logs、metrics 或 traces。创建需要
pipelines.create;后续编辑、暂停/恢复、回填和删除分别使用对应的 pipelines.* 权限。Documentation Index
Fetch the complete documentation index at: /llms.txt
Use this file to discover all available pages before exploring further.
curl -X POST http://localhost:5080/api/v1/scheduled_pipelines \
-H "authorization: Bearer $MS_JWT" \
-H 'content-type: application/json' \
-d '{
"name": "normalize-app",
"source_stream": "app_raw",
"target_stream": "app",
"function_steps": {
"language": "vrl",
"signal_type": "logs",
"steps": [
{
"transform_name": "normalize-level",
"script": ".level = downcase!(string!(.level))"
}
]
},
"cron": "every:5m",
"lookback_secs": 300,
"enabled": true
}'
创建定时运行的来源—转换—目标流水线。
curl -X POST http://localhost:5080/api/v1/scheduled_pipelines \
-H "authorization: Bearer $MS_JWT" \
-H 'content-type: application/json' \
-d '{
"name": "normalize-app",
"source_stream": "app_raw",
"target_stream": "app",
"function_steps": {
"language": "vrl",
"signal_type": "logs",
"steps": [
{
"transform_name": "normalize-level",
"script": ".level = downcase!(string!(.level))"
}
]
},
"cron": "every:5m",
"lookback_secs": 300,
"enabled": true
}'
POST /api/v1/scheduled_pipelines
curl -X POST http://localhost:5080/api/v1/scheduled_pipelines \
-H "authorization: Bearer $MS_JWT" \
-H 'content-type: application/json' \
-d '{
"name": "normalize-app",
"source_stream": "app_raw",
"target_stream": "app",
"function_steps": {
"language": "vrl",
"signal_type": "logs",
"steps": [
{
"transform_name": "normalize-level",
"script": ".level = downcase!(string!(.level))"
}
]
},
"cron": "every:5m",
"lookback_secs": 300,
"enabled": true
}'
signal_type 可取 logs、metrics 或 traces。创建需要
pipelines.create;后续编辑、暂停/恢复、回填和删除分别使用对应的 pipelines.* 权限。此页面对您有帮助吗?