All Products
Search
Document Center

Dataphin:Create a RabbitMQ data source

Last Updated:May 28, 2025

By creating a RabbitMQ data source, you can enable Dataphin to read business data from RabbitMQ or write data to RabbitMQ. This topic describes how to create a RabbitMQ data source.

Permission requirements

Dataphin allows only users who have the Create Data Source permission or users who are assigned the super administrator, data source administrator, architecture designer, or project administrator role to create data sources.

Procedure

  1. In the top navigation bar of the Dataphin homepage, choose Management Center > Datasource Management.

  2. On the Datasource page, click +Create Data Source.

  3. On the Create Data Source page, select RabbitMQ in the Message Queue section.

    If you have recently used RabbitMQ, you can also select RabbitMQ in the Recently Used section. You can also enter keywords in the search box to quickly search for RabbitMQ.

  4. On the Create RabbitMQ Data Source page, configure the connection parameters.

    1. Configure the basic information of the data source.

      Parameter

      Description

      Datasource Name

      The name must meet the following requirements:

      • The name can contain only Chinese characters, letters, digits, underscores (_), and hyphens (-).

      • The name can be up to 64 characters in length.

      Datasource Code

      After you configure the data source code, you can reference tables in the data source in a Flink_SQL node by using the data source code.table name or data source code.schema.table name format. If you want to automatically access the data source in the corresponding environment based on the current environment, use the variable format ${data source code}.table or ${data source code}.schema.table. For more information, see Develop Dataphin data source tables.

      Important
      • The data source code cannot be modified after it is configured successfully.

      • After the data source code is configured successfully, you can preview data on the object details page in the asset directory and asset inventory.

      • In Flink SQL, only MySQL, Hologres, MaxCompute, Oracle, StarRocks, Hive, and SelectDB data sources are currently supported.

      Version

      Only version 3.6.5 is supported.

      Data Source Description

      A brief description of the data source. The description cannot exceed 128 characters.

      Data Source Configuration

      Select the data source that you want to configure:

      • If the business data source is divided into production and development data sources, select Production + Development Data Source.

      • If the business data source is not divided into production and development data sources, select Production Data Source.

      Tag

      You can categorize and label data sources based on tags. For information about how to create tags, see Manage data source tags.

    2. Configure the connection parameters between the data source and Dataphin.

      If you select Production + Development data source for your data source configuration, you need to configure the connection information for the Production + Development data source. If your data source configuration is Production data source, you only need to configure the connection information for the Production data source.

      Note

      In general, the production data source and development data source should be configured as different data sources to achieve environment isolation and reduce the impact of the development data source on the production data source. However, Dataphin also supports configuring them as the same data source with identical parameter values.

      Parameter

      Description

      Server Address

      Enter the IP address and port number of the server. Only one server address is supported. You cannot add more server addresses.

      Username, Password

      Enter the username and password (or credential) of the authentication user. To ensure that tasks can be executed properly, make sure that the user has the required data permissions.

      Virtual Host

      Enter the Virtual Host. The default value is /.

  5. Click OK to create the RabbitMQ data source.