本文档介绍如何将洞察数据从BMQ写入MySQL。

内容洞察数据流配置，支持将客户BMQ中的内容数据，自动写入指定的MySQL中，客户侧可按照如下指引，完成基础配置，实现自动化写入。

前置准备：

• 开通洞察数据源，详见：基础配置--内容洞察平台-火山引擎

• 完善洞察数据写入BMQ自动化配置，详见：BMQ配置--内容洞察平台-火山引擎

• 创建Flink资源，详见：入门指引--流式计算 Flink版-火山引擎

创建MySQL资源

请参考文档：创建实例--云数据库 MySQL 版-火山引擎

配置白名单并绑定实例

创建数据库与数据表

创建数据库，详见：创建数据库和账号--云数据库 MySQL 版-火山引擎

创建数据表：

CREATE TABLE `insight_post_1` (
    `origin_id` varchar(32) NOT NULL COMMENT '原始ID',
    `post_id` varchar(32) NOT NULL COMMENT '发文ID',
    `publish_time` datetime NOT NULL COMMENT '发布时间',
    `push_ready_time` datetime DEFAULT NULL COMMENT '可消费时间',
    `main_domain` varchar(128) DEFAULT '' COMMENT '主域名',
    `domain` varchar(128) DEFAULT '' COMMENT '子域名',
    `url` varchar(128) DEFAULT '' COMMENT '网页URL',
    `title` text DEFAULT NULL COMMENT '标题',
    `feature` json DEFAULT NULL COMMENT '算法信息',
    `poi` json DEFAULT NULL COMMENT 'POI信息',
    `status` tinyint DEFAULT 1 COMMENT '视频状态',
    `post_type` tinyint DEFAULT 0 COMMENT '发文类型',
    `video_info` json DEFAULT NULL COMMENT '视频信息',
    `based_location` json DEFAULT NULL COMMENT '相关位置',
    `matched_task_ids` varchar(256) DEFAULT NULL COMMENT '命中任务ID',
    PRIMARY KEY (`origin_id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_general_ci COMMENT='内容洞察数据表'

创建账号供洞察使用

创建洞察数据流

第一步：创建数据流，配置对应vpc与flink资源

第二步：完善节点信息，提交保存

第三步：校验数据流，校验通过后发布上线

控制台示意	说明
点击发布数据流	节点编辑完成，且节点标识提示正确无误的情况下，可点击按钮【发布草稿到线上】发布数据流。
选择TOS桶并上传样例数据	发布数据流前需进行发布校验，上传样例数据，以确保数据可正常按照设置写入下游。 选择TOS桶以存储相关文件，并选择/上传将要进行校验的样例数据。 注意： 请上传json格式的样例数据 上传的新内容将会保存为文件并上传至已选择桶的 insight_verify/ 路径下，如没有该路径则会自动创建 洞察数据校验样例可参考： insight_sample.json 11.35KB
点击启动校验	样例数据上传完毕后，点击按钮【启动校验】 校验预计需要3-5分钟请耐心等待
校验通过，发布数据流	校验通过后，可查看数据预览，确认无误后可发布数据流。 发布预计需要3-5分钟，请耐心等待。 发布成功后，前端状态变更为发布成功。

数据流发布上线后，可连接实例，以查询数据
通过命令行连接实例--云数据库 MySQL 版-火山引擎