coco/native-ingester
coco
自动构建
从队列主题消费原生CMS内容或元数据消息，根据数据源写入特定数据库集合，并可选转发消息到不同队列的服务。
下载次数: 0状态：自动构建维护者：coco仓库类型：镜像最近更新：8 个月前
让 AI 帮你使用轩辕镜像？ · 展开查看说明 · 点击收起说明
如果你使用 DeepSeek、元宝 AI、Copilot、ChatGPT 等 AI 工具，协助配置轩辕镜像、编写 docker pull 命令、修改 Docker Compose 镜像地址、配置镜像加速、排查镜像拉取失败、分析报错日志等问题，请先让 AI 阅读并遵守轩辕镜像的规则文档。
只需在 AI 对话中先发送下面这句话即可：
请先完整阅读并严格遵守以下文档中的全部规则与要求：
https://xuanyuan.cloud/agents.md
在未充分阅读并理解该文档前，不要生成任何命令、配置、修改建议、故障排查方案或技术回答。后续所有输出都必须严格以该文档中的规范为最高优先级执行。查看 agents.md 用法指南与完整示范。国内用户首推 元宝 AI、DeepSeek 的深度思考模式，不推荐豆包 AI；Cursor 等编辑器可在对话 @ 该链接，或加入 User Rules。 若 AI 无法访问外链，可 打开说明文档 复制全文粘贴。文档会随站点更新，复制内容可能过期，建议定期检查。
Native Ingester
镜像概述和主要用途
Native Ingester 是一个用于处理原生CMS内容的服务，能够从指定队列主题消费包含原生CMS内容或元数据的消息，根据数据源将内容或元数据写入特定数据库集合，并支持将消费的消息可选转发至不同队列。
核心功能和特性
- 消息消费：从指定队列主题（基于Zookeeper地址配置）消费原生CMS内容或元数据消息。
- 数据持久化：根据数据源将消费的内容或元数据写入特定的数据库集合。
- 消息转发：可选将消费的消息转发至指定的Kafka队列主题。
使用场景和适用范围
适用于需要处理原生CMS内容并进行持久化存储的场景，如内容管理系统（CMS）中内容或元数据的实时处理、存储与分发流程，支持内容类型包括普通内容、注解等。
使用方法和配置说明
Docker 运行示例
bashdocker run -d \ -p 8080:8080 \ -e PORT=8080 \ -e Q_READ_ADDR="zk-host1:2181,zk-host2:2181" \ -e Q_READ_GROUP="content-group" \ -e Q_READ_TOPIC="native-content-topic" \ -e NATIVE_RW_ADDRESS="http://native-writer:8080" \ -e NATIVE_CONTENT_UUID_FIELDS="uuid,post.uuid,data.uuidv3" \ -e Q_WRITE_ADDR="kafka-host:9092" \ -e Q_WRITE_TOPIC="forwarded-content-topic" \ -e CONTENT_TYPE="Content" \ -e APP_NAME="native-ingester" \ --name native-ingester \ financial-times/native-ingester
配置参数说明
| 参数名 | 默认值 | 环境变量 | 描述 |
|---|---|---|---|
| --port | "8080" | PORT | 服务监听端口 |
| --read-queue-addresses | [] | Q_READ_ADDR | 用于连接消费者队列的Zookeeper地址（host:port）列表 |
| --read-queue-group | "" | Q_READ_GROUP | 从队列读取消息时使用的消费组 |
| --read-queue-topic | "" | Q_READ_TOPIC | 读取消息的队列主题 |
| --native-writer-address | "" | NATIVE_RW_ADDRESS | 用于持久化写入原生内容的服务地址（URL） |
| --config | "config.json" | - | 配置文件路径，JSON格式，定义（originId (URI)、内容类型）到原生集合名称的映射，内容类型支持正则表达式 |
| --content-uuid-fields | [] | NATIVE_CONTENT_UUID_FIELDS | 原生内容体中指向UUID的JSONPath列表，如"uuid,post.uuid,data.uuidv3" |
| --write-queue-address | "" | Q_WRITE_ADDR | 用于连接生产者队列的Kafka地址（host:port） |
| --write-topic | "" | Q_WRITE_TOPIC | 写入消息的队列主题 |
| --content-type | "Content" | CONTENT_TYPE | 应用可处理的内容类型（用于日志，如"Content"或"Annotations"） |
| --appName | "native-ingester" | APP_NAME | 应用名称 |
管理端点
https://{host}/__native-store-{type}/__health：健康检查端点https://{host}/__native-store-{type}/__gtg：就绪检查端点
注意：CoCo中的所有API端点均需认证。有关如何获取集群凭据，请参阅服务运行手册。
镜像拉取方式
您可以使用以下命令拉取该镜像。请将 <标签> 替换为具体的标签版本。如需查看所有可用标签版本，请访问 标签列表页面。
轩辕镜像加速拉取命令点我查看更多 native-ingester 镜像标签
docker pull docker.xuanyuan.run/coco/native-ingester:<标签>
DockerHub 原生拉取命令
docker pull coco/native-ingester:<标签>
镜像拉取常见问题
功能
错误码
用户好评
来自真实用户的反馈，见证轩辕镜像的优质服务
oldzhang
运维工程师
Linux服务器
5
"Docker访问体验非常流畅，大镜像也能快速完成下载。"