Before you begin real-time development, you must prepare the necessary cloud resources. These preparations include setting up a Ververica Flink computing source, activating and configuring Quick BI (optional), and preparing your data source. This guide will walk you through the cloud resource preparations needed for this tutorial.
Step 1: Activate and configure real-time computing Flink edition and Quick BI
Main flow | Description | Operation guide |
Activate real-time computing Flink edition | Purchase real-time computing Flink edition. | |
Activate Quick BI (optional) | Purchase Quick BI. Important Optional, you can also use other BI tools for subsequent visual analytics. | |
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. Already created project spaces do not support re-creation. It is recommended to use names like flink_dataphin_001. |
Step 2: Prepare data source
Create a MySQL 8.0 instance via RDS, retrieve the RDS instance ID, and configure a whitelist in the RDS console. For more information, see Create RDS MySQL instance. This tutorial uses 'flink_dataphin' as the example RDS data source name.
Sign in to the MySQL instance and execute the following commands to create a database and data tables.
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';