
inlong/agentInLong Agent Docker镜像用于开发和体验环境,提供文件系统监控、数据采集及转发至代理的功能,支持通过配置文件路径、数据源类型等参数实现文件数据的采集与发送,便于快速验证文件数据采集场景。
DirectoryTrigger监控指定文件夹下的文件生成事件TextFileSource读取文本文件内容ProxySink将数据发送至代理服务MemoryChannel作为数据传输通道适用于开发环境中快速测试文件数据采集流程,验证文件监控、文本读取及代理转发功能,支持含正则表达式的文件路径配置。
bashdocker pull inlong/agent:latest
bashdocker run -d --name agent -p 8008:8008 \ -e MANAGER_OPENAPI_IP=manager_opeapi_ip -e DATAPROXY_IP=dataproxy_ip \ -e MANAGER_OPENAPI_PORT=8082 -e DATAPROXY_PORT=46801 inlong/agent
环境变量说明:
MANAGER_OPENAPI_IP:Manager OpenAPI服务IP地址DATAPROXY_IP:DataProxy服务IP地址MANAGER_OPENAPI_PORT:Manager OpenAPI服务端口(默认8082)DATAPROXY_PORT:DataProxy服务端口(默认46801)通过HTTP POST请求添加文件采集任务:
bashcurl --location --request POST 'http://localhost:8008/config/job' \ --header 'Content-Type: application/json' \ --data '{ "job": { "dir": { "path": "", "pattern": "/data/inlong-agent/test.log" }, "trigger": "org.apache.inlong.agent.plugin.trigger.DirectoryTrigger", "id": 1, "thread": { "running": { "core": "4" } }, "name": "fileAgentTest", "source": "org.apache.inlong.agent.plugin.sources.TextFileSource", "sink": "org.apache.inlong.agent.plugin.sinks.ProxySink", "channel": "org.apache.inlong.agent.plugin.channel.MemoryChannel" }, "proxy": { "bid": "bid10", "tid": "bid10" }, "op": "add" }'
| 参数 | 说明 |
|---|---|
| job.dir.pattern | 配置读取文件路径,可包含正则表达式 |
| job.trigger | 触发器名称,默认值为DirectoryTrigger,功能是监控文件夹下文件生成事件 |
| job.source | 使用的数据源类型,默认值为TextFileSource,用于读取文本文件 |
| job.sink | 使用的写入器类型,默认值为ProxySink,用于将消息发送至代理 |
| proxy.bid | 写入代理时使用的bid类型 |
| proxy.tid | 写入代理时使用的tid类型 |
| job.id | 任务唯一标识ID |
| job.name | 任务名称 |
| job.thread.running.core | 任务运行核心线程数 |
| job.channel | 数据传输通道类型,默认使用MemoryChannel(内存通道) |
op: "add":表示添加任务操作
manifest unknown 错误
TLS 证书验证失败
DNS 解析超时
410 错误:版本过低
402 错误:流量耗尽
身份认证失败错误
429 限流错误
凭证保存错误
来自真实用户的反馈,见证轩辕镜像的优质服务