Skip to content

Commit

Permalink
[Feature] [InLong-Agent] Modify bid and tid to inlongGroupId and inlo…
Browse files Browse the repository at this point in the history
…ngStreamId (apache#171)

Co-authored-by: EMsnap <stingpeng@tencent.com>
  • Loading branch information
EMsnap and EMsnap committed Nov 4, 2021
1 parent c45c6cb commit d69b1ae
Show file tree
Hide file tree
Showing 2 changed files with 17 additions and 17 deletions.
18 changes: 9 additions & 9 deletions docs/modules/agent/quick_start.md
Original file line number Diff line number Diff line change
Expand Up @@ -61,9 +61,9 @@ agent.http.port=Available ports
"sink": "org.apache.inlong.agent.plugin.sinks.ProxySink",
"channel": "org.apache.inlong.agent.plugin.channel.MemoryChannel"
},
"bus": {
"bid": "bid10",
"tid": "bid10"
"proxy": {
"groupId": "groupId10",
"streamId": "groupId10"
},
"op": "add"
}'
Expand All @@ -74,8 +74,8 @@ agent.http.port=Available ports
- job.trigger: Trigger name, the default is DirectoryTrigger, the function is to monitor the files under the folder to generate events
- job.source: The type of data source used, the default is TextFileSource, which reads text files
- job.sink:The type of writer used, the default is ProxySink, which sends messages to the proxy
- proxy.bid: The bid type used when writing proxy, bid is business id showed on data access in inlong-manager, not the topic name.
- proxy.tid: The tid type used when writing proxy, tid is the data flow id showed on data flow window in inlong-manager
- proxy.groupId: The groupId type used when writing proxy, groupId is group id showed on data access in inlong-manager, not the topic name.
- proxy.streamId: The streamId type used when writing proxy, streamId is the data flow id showed on data flow window in inlong-manager


## 4、eg for directory config
Expand Down Expand Up @@ -136,8 +136,8 @@ curl --location --request POST'http://localhost:8008/config/job' \
"channel": "org.apache.inlong.agent.plugin.channel.MemoryChannel"
},
"proxy": {
"bid": "bid10",
"tid": "bid10"
"group": "group10",
"group": "group10"
},
"op": "add"
}'
Expand Down Expand Up @@ -177,8 +177,8 @@ curl --location --request POST'http://localhost:8008/config/job' \
"channel": "org.apache.inlong.agent.plugin.channel.MemoryChannel"
},
"proxy": {
"bid": "bid10",
"tid": "bid10"
"groupId": "groupId10",
"streamId": "streamId10"
},
"op": "add"
}'
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -61,8 +61,8 @@ curl --location --request POST 'http://localhost:8008/config/job' \
"channel": "org.apache.inlong.agent.plugin.channel.MemoryChannel"
},
"proxy": {
"bid": "bid10",
"tid": "bid10"
"groupId": "groupId10",
"streamId": "streamId10"
},
"op": "add"
}'
Expand All @@ -73,8 +73,8 @@ curl --location --request POST 'http://localhost:8008/config/job' \
- job.trigger: 触发器名称,默认为DirectoryTrigger,功能为监听文件夹下的文件产生事件,任务运行时已有的文件不会读取
- job.source: 使用的数据源类型,默认为TextFileSource,读取文本文件
- job.sink:使用的写入器类型,默认为ProxySink,发送消息到dataproxy中
- proxy.bid: 写入proxy时使用的bid,bid是指manager界面中,数据接入中业务信息的业务ID,此处不是创建的tube topic名称
- proxy.tid: 写入proxy时使用的tid,tid是指manager界面中,数据接入中数据流的数据流ID
- proxy.groupId: 写入proxy时使用的groupId,groupId是指manager界面中,数据接入中业务信息的业务ID,此处不是创建的tube topic名称
- proxy.streamId: 写入proxy时使用的streamId,streamId是指manager界面中,数据接入中数据流的数据流ID

## 4、可支持的路径配置方案

Expand Down Expand Up @@ -133,8 +133,8 @@ curl --location --request POST 'http://localhost:8008/config/job' \
"channel": "org.apache.inlong.agent.plugin.channel.MemoryChannel"
},
"proxy": {
"bid": "bid10",
"tid": "bid10"
"groupId": "groupId",
"streamId": "streamId"
},
"op": "add"
}'
Expand Down Expand Up @@ -175,8 +175,8 @@ curl --location --request POST 'http://localhost:8008/config/job' \
"channel": "org.apache.inlong.agent.plugin.channel.MemoryChannel"
},
"proxy": {
"bid": "bid10",
"tid": "bid10"
"groupId": "groupId",
"streamId": "streamId"
},
"op": "add"
}'
Expand Down

0 comments on commit d69b1ae

Please sign in to comment.