Step 2: Plan a real-time project

Updated at:

This topic describes how to create and attach a Ververica Flink compute source, a data source, and a real-time project for this tutorial.

Step 1: Create a Ververica Flink compute source

  1. On the Dataphin home page, click Planning in the top menu bar.

  2. Follow the steps in the following figure to go to the Create Ververica Flink Compute Source page.

    image..png

  3. On the Create Compute Source page, configure the parameters.

    Parameter

    Description

    Compute Type

    Select Ververica Flink.

    Region

    Select the region where the compute source is located. For example, China (Hangzhou).

    Access Method

    Select an access method for the compute source. A VPC network is recommended.

    AccessKey ID and AccessKey Secret

    Enter the AccessKey ID and AccessKey secret of an account that has permissions to access the fully managed Flink project.

    Obtain the AccessKey ID and AccessKey secret for your account on the User Information Management page.

    image..png

    Flink Workspace ID

    Select the Flink Workspace ID for the Ververica Flink compute source, which is flink_dataphin_default.

    Flink Project

    Select the Project for the Ververica Flink compute source.

    Compute Source Name

    Enter flink_dataphin.

    Description

    Enter a brief description of the compute source. For example, Real-time development demo.

  4. Click Test and Submit. The system tests the connectivity and creates the compute source.

Step 3: Create a project

  1. Follow the steps in the following figure to open the Create Project dialog box.

    image.png

  2. In the Production and Development Type step, select Basic Mode and click Next.

  3. In the Create Project dialog box, configure the project parameters.

    Parameter

    Description

    Data Section

    Leave this parameter empty.

    Project English Name

    Enter flink_dataphin.

    Project Name

    Enter flink_dataphin.

    Compute Source Type

    Enable the real-time engine and select the Ververica Flink compute source. For the Flink stream processing compute source, select the flink_dataphin compute source that you created.

    Space Type

    Select General Layer.

    Security Settings

    Use the default configurations.

    More Settings

    Use the default configurations.

  4. Click OK to create the real-time project.

Step 4: Create a data source

  1. On the Dataphin home page, click Management Hub in the top menu bar.

  2. Follow the steps in the following figure to open the Create Data Source dialog box.

    image.png

  3. Under Relational Data Source, select MySQL.

  4. In the Create MySQL Data Source dialog box, configure the data source information.

    Parameter

    Description

    Data Source Name

    Enter flink_dataphin.

    Version

    Select MySQL 8.

    Data Source Description

    Enter a brief description of the data source. For example, Source data for real-time development.

    Data Source Configuration

    Select Production Data Source.

    Tags

    Leave this parameter empty by default.

    JDBC URL

    Enter the URL in the jdbc:mysql://host:port/dbname format. To view the host:port information, log on to the MySQL instance product page. The following figure shows an example:

    image.png

    Important
    • Make sure that you have added the IP address of Dataphin to the whitelist of the database. Otherwise, the connection may fail. For more information, see Data source whitelist configuration.

    • If you use a private endpoint, make sure that the database and the Dataphin instance are in the same region. For more information, see Network connectivity solutions.

    Username, Password

    Enter the username and password used to log on to the data source.

    SSL Encryption

    If your MySQL data source is configured with Secure Sockets Layer (SSL) encryption, click Enable. Then, upload the Truststore certificate and enter the Truststore certificate password to encrypt data transmission.

    Type

    Select Alibaba Cloud Database.

    Note

    Select an access method based on the network type specified when the database was created.

    Public Network Database: A database that can be accessed over the public network.

    Alibaba Cloud Database: A database created on Alibaba Cloud.

    Self-managed Database on ECS (VPC): A self-managed database that uses a VPC.

    Advanced Settings

    Use the default configurations.

  5. Click Test Connection.

  6. After the test is successful, click OK.