腾讯云消息队列 CKafka 新建数据流出任务 - 时序数据库(CTSDB)
文档简介:
操作场景:
CKafka 连接器提供数据流出能力,您可以将 CKafka 数据分发至时序数据库(CTSDB)以对数据进行存储、查询和分析。
操作场景
CKafka 连接器提供数据流出能力,您可以将 CKafka 数据分发至时序数据库(CTSDB)以对数据进行存储、查询和分析。
前提条件
该功能目前依赖时序数据库(CTSDB)产品,使用时需开通相关产品功能。
操作步骤
1. 登录 CKafka 控制台。
2. 在左侧导航栏单击连接器 > 任务列表,选择好地域后,单击新建任务。
3. 填写任务名称,任务类型选择数据流出,数据目标类型选择 时序数据库(CTSDB),单击下一步。
4. 配置数据源信息。

Topic 类型:选择数据源 Topic
弹性 Topic:选择提前创建好的弹性 Topic,详情参见 Topic 管理。
CKafka 实例内 Topic:选择在 CKafka 创建好的实例和 Topic,若实例设置了ACL 策略,请确保选中的 topic 有读写权限。详情参见 创建 Topic。
起始位置:选择转储时历史消息的处理方式,topic offset 设置。
5. 设置上述信息后,单击下一步,单击预览 Topic 消息,将会选取源 Topic 中的第一条消息进行解析。
说明
目前解析消息需要满足以下条件:
消息为 JSON 字符串结构。
源数据必须为单层 JSON 格式,嵌套 JSON 格式可使用 数据处理 进行简单的消息格式转换。
6. (可选)开启对源数据进行数据处理按钮,具体配置方法请参见 简单数据处理。
7. 单击下一步,配置数据目标信息。


数据目标:选择提前创建好的 CTSDB 连接。
metic:选择数据流出的数据库表。
8. 单击提交,可以在任务列表看到刚刚创建的任务,在状态栏可以查看任务创建进度。