StreamSets 管理 SDC Edge上的pipeline

发布时间：2020-12-14 05:06:15 所属栏目：百科来源：网络整理

导读：可选的方式： ui （data colelctor）发送命令 UI 主要是创建edge pipeline 的时候进行edge server 的配置默认是 http://localhost:18633 发送命令启动时格式如下： bin/edge -start=pipelineID -runtimeParameters=‘{"parameter_name1":"parameter_valu

可选的方式：

ui （data colelctor）
发送命令

UI

主要是创建edge pipeline 的时候进行edge server 的配置 默认是 http://localhost:18633

发送命令

启动时
格式如下：

bin/edge -start=<pipelineID> -runtimeParameters=‘{"<parameter_name1>":"<parameter_value1>","<parameter_name2":"<parameter_value2>"}‘

启动后(rest api)

基本：
curl -X POST http://<SDCEdge_hostname>:<port>/rest/v1/pipeline/<pipelineID>/start
包含参数：
curl -X POST http://<SDCEdge_hostname>:<port>/rest/v1/pipeline/<pipelineID>/start -H ‘Content-Type: application/json;charset=UTF-8‘ --data-binary ‘{"<parameter_name1>":"<parameter_value1>","<parameter_name2":"<parameter_value2>"}‘
预览数据：
curl -X POST http://<SDCEdge_hostname>:18633/rest/v1/pipeline/<pipelineID>/preview
curl -X GET http://<SDCEdge_hostname>:18633/rest/v1/pipeline/<pipelineID>/preview/<previewerID>/status
curl -X GET http://<SDCEdge_hostname>:18633/rest/v1/pipeline/<pipelineID>/preview/<previewerID>
curl -X DELETE http://<SDCEdge_hostname>:18633/rest/v1/pipeline/<pipelineID>/preview/<previewerID>
校验：
curl -X GET http://<SDCEdge_hostname>:18633/rest/v1/pipeline/<pipelineID>/validate
状态管理：
curl -X GET http://<SDCEdge_hostname>:18633/rest/v1/pipeline/<pipelineID>/status
curl -X POST http://<SDCEdge_hostname>:18633/rest/v1/pipeline/<pipelineID>/stop
curl -X POST http://<SDCEdge_hostname>:18633/rest/v1/pipeline/<pipelineID>/resetOffset
curl -X GET http://<SDCEdge_hostname>:18633/rest/v1/pipeline/<pipelineID>/metrics

参考资料

https://streamsets.com/documentation/datacollector/latest/help/datacollector/UserGuide/Edge_Mode/EdgePipelines_Manage.html#concept_tqk_dbb_4db

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!