数据湖探索 DLI-创建并提交Flink OpenSource SQL作业:步骤2：准备数据输出通道

时间：2024-05-23 09:15:31

数据湖探索 DLI

步骤2：准备数据输出通道

采用RDS作为数据输出通道，创建RDS MySQL实例，具体操作请参见《云数据库MySQL快速入门》中的“MySQL快速入门”章节。

登录RDS管理控制台。
在管理控制台左上角选择区域。
单击“购买数据库实例”配置相关参数。主要参数的填下说明如下，其他参数保持默认值即可。
- 计费模式：按需付费
- 区域：选择与DLI服务相同的区域
- 实例名称：rds-dliflink
- 数据库引擎：MySQL
- 数据库版本：8.0
- 实例类型：主备
- 存储类型：SSD云盘
- 主可用区：自定义
- 备可用区：自定义
- 时区：默认
- 性能规格：2 vCPUs | 8 GB
- 存储空间：40GB
- 虚拟私有云、子网：选择1中创建的虚拟私有云和子网。
- 数据库端口：3306
- 安全组：选择1中创建的安全组。
- 管理员密码：****（请妥善管理密码，系统无法获取您设置的密码内容）
- 确认密码：****
- 参数模板：Default-MySQL-8.0
- 只读实例：暂不购买
单击“立即购买”，确认规格信息。
单击“提交”，完成RDS实例的创建。

登录MySQL，并使用下述命令在flink库下创建orders表。

登录MySQL，单击“SQL窗口”，在SQL查询页面输入以下创建表语句，创建RDS MySQL表。

CREATE TABLE `flink`.`orders` (
	`order_id` VARCHAR(32) NOT NULL,
	`order_channel` VARCHAR(32) NULL,
	`order_time` VARCHAR(32) NULL,
	`pay_amount` DOUBLE UNSIGNED NOT NULL,
	`real_pay` DOUBLE UNSIGNED NULL,
	`pay_time` VARCHAR(32) NULL,
	`user_id` VARCHAR(32) NULL,
	`user_name` VARCHAR(32) NULL,
	`area_id` VARCHAR(32) NULL,
	PRIMARY KEY (`order_id`)
)	ENGINE = InnoDB
	DEFAULT CHARACTER SET = utf8mb4
	COLLATE = utf8mb4_general_ci;

上一篇：数据湖探索 DLI-创建并提交Flink OpenSource SQL作业:操作流程

下一篇：数据湖探索 DLI-创建并提交Flink OpenSource SQL作业:操作流程