coco/content-collection-unfolder

content-collection-unfolder

概述

content-collection-unfolder是统一发布平台（UPP）的核心服务之一，负责通过relations-api识别内容集合中新增/删除的成员及头条文章，将映射后的内容集合转发至content-collection-rw-neo4j写入Neo4j数据库；若收到写入服务的200响应，则从document-store-api获取相关内容，并将其放入Kafka的Post Publication主题以触发后续通知流程。

核心功能

1. 从relations-api获取内容集合的新增/删除成员及头条文章
2. 将内容集合转发至content-collection-rw-neo4j写入Neo4j数据库
3. 通过document-store-api解析新增/删除内容及头条文章的详情
4. 将内容消息发送至Kafka指定主题，支持后续通知生成

使用场景

适用于UPP平台内内容集合的自动化处理场景，主要用于content-package类型的内容集合展开，确保内容更新同步至数据库并触发下游通知，支撑内容发布后的全链路流程。

配置说明

服务支持通过命令行参数或环境变量配置关键参数，核心配置项包括：

• --app-port: 服务监听端口（默认8080）
• --unfolding-whitelist: 需要展开的集合类型列表（默认["content-package"]）
• --writer-uri: content-collection-rw-neo4j的写入接口地址
• --content-resolver-uri: document-store-api的内容解析接口地址
• --relations-resolver-uri: relations-api的关系查询接口地址
• --kafka-write-topic: Kafka消息写入主题（默认PostPublicationEvents）
• --kafka-proxy-address: Kafka代理服务地址

Docker部署示例

Docker Run命令

bash
docker run -d \
  -p 8080:8080 \
  -e APP_PORT=8080 \
  -e UNFOLDING_WHITELIST='["content-package"]' \
  -e WRITER_URI="http://content-collection-rw-neo4j:8080/__content-collection-rw-neo4j/content-collection/" \
  -e CONTENT_RESOLVER_URI="http://document-store-api:8080/__document-store-api/content/" \
  -e RELATIONS_RESOLVER_URI="http://relations-api:8080/__relations-api/contentcollection/{uuid}/relations" \
  -e KAFKA_WRITE_TOPIC="PostPublicationEvents" \
  -e KAFKA_PROXY_ADDRESS="http://kafka-proxy:8080" \
  docker.xuanyuan.run/coco/content-collection-unfolder

服务端点

PUT请求

提交内容集合进行处理：

bash
curl -X PUT --data "@cc.json" localhost:8080/content-collection/content-package/45163790-eec9-11e6-abbc-ee7d9c5b3b90

预期响应：200（无响应体）；若依赖服务返回非200状态，则转发该响应；若Kafka处理失败，仍返回200但日志会记录错误。

健康检查

服务提供以下管理端点：

• /__gtg: 全局健康检查（所有依赖服务正常时返回200）
• /__build-info: 服务构建信息
• /__ping: 心跳检测（返回200）
• /__health: 详细健康检查（验证relations-api、content-collection-rw-neo4j、document-store-api、Kafka的连通性）