Prepare cloud resources for Dataphin real-time development - Dataphin

Before real-time development, prepare the required cloud resources: a Ververica Flink computing source, Quick BI (optional), and a data source.

Step 1: Activate real-time computing Flink edition and Quick BI

Task	Description	Reference
Activate real-time computing Flink edition	Purchase real-time computing Flink edition.	Activate real-time computing Flink edition
Activate Quick BI (optional)	Purchase Quick BI. Important Optional. You can use other BI tools for visual analytics.	Quick BI purchases, upgrades, renewals, overdue payments
Create Flink project space	Create a Flink project space with the project name flink_dataphin. Important Alibaba Cloud real-time computing Flink edition uses a global project space. Existing project spaces cannot be recreated. Use a unique name such as flink_dataphin_001.	Manage project space

Step 2: Prepare the data source

Create a MySQL 8.0 instance in RDS, retrieve the instance ID, and configure a whitelist (Create RDS MySQL instance). This tutorial uses 'flink_dataphin' as the data source name.

create database flink_dataphin; //Create flink_dataphin database

use flink_dataphin; //Use flink_dataphin database

//Order table
CREATE TABLE `oms_orders` (
  `id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT 'Order ID',
  `buyer_id` bigint(20) DEFAULT NULL COMMENT 'User ID',
  `sku_type` char(32) DEFAULT NULL COMMENT 'Product type',
  `sku_quantity` int DEFAULT NULL COMMENT 'Product quantity',
  `gmt_create` datetime DEFAULT NULL COMMENT 'Creation time',
  PRIMARY KEY (`id`)
) COMMENT='Order table';

//Result table
CREATE TABLE `ads_gross` (
  `prod_code` char(32) COMMENT 'Product code',
  `sale_num` int DEFAULT NULL COMMENT 'Sales quantity',
   primary key (prod_code)
) COMMENT='Category sales total result table';