coco/video-mapper

video-mapper

镜像概述

本镜像基于Financial-Times的video-mapper项目，用于监听Kafka（或kafka-bridge）的NativeCmsPublicationEvents事件，获取视频数据并转换为Content格式，再将结果发送至Kafka的CmsPublicationEvents主题。

核心功能

1. 监听Kafka的NativeCmsPublicationEvents主题，接收原生视频数据
2. 将原生视频数据转换为标准Content格式
3. 将转换后的Content数据发送至Kafka的CmsPublicationEvents主题
4. 提供HTTP /map 端点，用于验证映射逻辑（仅验证，不发送消息至队列）

使用场景

适用于视频内容管理系统中，将原生视频数据转换为统一的Content格式，以便后续内容分发、存储或分析等环节使用。

配置说明

需通过环境变量配置以下参数：

• Q_ADDR：队列服务地址（如Kafka-bridge地址）
• Q_GROUP：消费组名称（示例：videoMapper）
• Q_READ_TOPIC：读取消息的主题（示例：NativeCmsPublicationEvents）
• Q_READ_QUEUE：读取队列类型（示例：kafka）
• Q_WRITE_TOPIC：写入消息的主题（示例：CmsPublicationEvents）
• Q_WRITE_QUEUE：写入队列类型（示例：kafka）
• Q_AUTHORIZATION：队列服务的授权密钥（需从集群etcd获取）

Docker部署示例

构建镜像

bash
docker build -t video-mapper .

运行容器

bash
# 获取授权密钥（需根据实际环境调整）
export Q_AUTHORIZATION=$(etcdctl get /ft/_credentials/kafka-bridge/authorization_key)

docker run -p 8080:8080 \
    --env "Q_ADDR=http://172.23.53.64:8080" \
    --env "Q_GROUP=videoMapper" \
    --env "Q_READ_TOPIC=NativeCmsPublicationEvents" \
    --env "Q_READ_QUEUE=kafka" \
    --env "Q_WRITE_TOPIC=CmsPublicationEvents" \
    --env "Q_WRITE_QUEUE=kafka" \
    --env "Q_AUTHORIZATION=$Q_AUTHORIZATION" \
    docker.xuanyuan.run/video-mapper

验证映射逻辑

1. 获取原生视频JSON格式数据（可参考https://gist.github.com/kovacshuni/d***e084d6fb3dc0aec6d6ee4239a5#file-message-on-nativecmspublicationevents-txt）
2. 向容器的 /map 端点发送POST请求，携带原生视频JSON数据（仅JSON内容，不含头部）
3. 应收到转换后的Content格式响应，示例如下：

json
{
  "contentUri": "http://brightcove-video-mapper-iw-uk-p.svc.ft.com/video/model/bad50c54-76d9-30e9-8734-b999c708aa4c",
  "payload": {
    "uuid": "bad50c54-76d9-30e9-8734-b999c708aa4c",
    "identifiers": [
      {
        "authority": "http://api.ft.com/system/BRIGHTCOVE",
        "identifierValue": "4492075574001"
      }
    ],
    "publishedDate": "2016-04-29T11:02:58.000Z",
    "mediaType": "video/mp4",
    "publishReference": "tid_123123",
    "lastModified": "2016-04-29T11:02:58.269Z"
  },
  "lastModified": "2016-04-29T11:02:58.269Z",
  "firstPublishedDate":"2016-04-29T11:02:58.000Z",
  "canBeDistributed": "yes"
}

注：此验证操作不会将消息发送至任何队列。