coco/methode-content-placeholder-mapper

methode-content-placeholder-mapper

镜像概述

Methode-content-placeholder-mapper（MCPM）是一个微服务，负责将Methode系统的内容占位符映射到UP模型的内容，映射结果分为两部分：一部分存入内容集合，另一部分存入补充内容集合（用于保留占位符的推广字段）。该服务消费特定的Apache Kafka主题组，对包含Methode占位符的消息进行映射后，将结果输出到另一个Kafka队列。

核心功能

1. Kafka消息处理：消费指定Kafka主题的消息，处理Methode内容占位符并生成UP模型内容。
2. HTTP直接转换：提供/map端点，接收Methode占位符 payload 并返回UP模型的映射结果。
3. 健康检查：支持/__health、/__gtg（服务就绪）和/__build-info端点，符合FT规范。

使用场景

• ***时报内部内容系统间的内容格式转换。
• 内容发布可用性监控（如Publish Availability Monitor工具调用/map端点验证占位符）。

配置说明

环境变量配置

通过环境变量设置服务参数：

• Q_READ_ADDR：读取消息的Kafka队列地址（多个地址用逗号分隔）。
• Q_WRITE_ADDR：写入结果的Kafka队列地址。
• Q_GROUP：Kafka消费组名称。
• Q_READ_TOPIC：消费的Kafka主题名称。
• Q_WRITE_TOPIC：写入的Kafka主题名称。
• DOCUMENT_STORE_API_ADDRESS：文档存储API地址。

命令行参数配置

通过命令行参数设置（优先级高于环境变量）：

• --read-queue-addresses：替代Q_READ_ADDR。
• --write-queue-address：替代Q_WRITE_ADDR。
• --group：替代Q_GROUP。
• --read-topic：替代Q_READ_TOPIC。
• --write-topic：替代Q_WRITE_TOPIC。
• --document-store-api-addresses：替代DOCUMENT_STORE_API_ADDRESS。

Docker部署示例

构建镜像

bash
docker build -t coco/methode-content-placeholder-mapper .

运行容器

bash
docker run --env Q_READ_ADDR="http://source1.queue.ft.com:8080,http://source2.queue.ft.com:8080" \
  --env Q_WRITE_ADDR="http://target.queue.ft.com:8080" \
  --env Q_GROUP="methode-messages" \
  --env Q_READ_TOPIC=NativeCmsPublicationEvents \
  --env Q_WRITE_TOPIC=CmsPublicationEvents \
  --env DOCUMENT_STORE_API_ADDRESS="http://%H:8080" \
  docker.xuanyuan.run/coco/methode-content-placeholder-mapper

HTTP端点说明

直接转换（/map）

• 请求方式：POST
• 功能：接收Methode占位符 payload，返回UP模型的映射结果。
• 响应状态：
  • 200 OK：转换成功（返回1或2个转换对象，分别对应内容集合和补充内容集合）。
  • 422 Unprocessable Entity：转换失败。
  • 404 Not Found：内容已删除。

健康检查相关

• /__health：健康状态检查。
• /__gtg：服务就绪状态检查。
• /__build-info：构建信息查询。