Realtime Compute for Apache Flink:Manage StarRocks catalogs

Création d'un catalogue StarRocks via la console

1. Connectez-vous à la console Realtime Compute for Apache Flink. Recherchez l'espace de travail que vous souhaitez gérer et cliquez sur Console dans la colonne Actions.

2. Dans le volet de navigation de gauche, cliquez sur Catalogs.

3. Sur la page Catalog List, cliquez sur Create Catalog. Dans l'assistant Create Catalog, sélectionnez StarRocks sous l'onglet Built-in Catalog, puis cliquez sur Next.

4. Configurez les paramètres du catalogue.

   Important

   La configuration d'un catalogue StarRocks ne peut pas être modifiée après sa création. Pour changer un paramètre, supprimez le catalogue existant et créez-en un nouveau.

   Parameter	Description	Required	Notes
   catalog name	Nom du catalogue StarRocks.	Yes	Lettres minuscules et chiffres uniquement. Les traits d'union (-), les underscores (_) et les lettres majuscules ne sont pas autorisés.
   endpoint	Endpoint d'un nœud FrontEnd (FE).	Yes	Format : jdbc:mysql://ip:port. Le port JDBC par défaut est 9030.
   dbname	Base de données StarRocks par défaut à laquelle se connecter.	Yes	—
   username	Nom d'utilisateur pour accéder à StarRocks.	Yes	—
   password	Mot de passe pour accéder à StarRocks.	Yes	Utilisez une variable au lieu d'un mot de passe en clair pour éviter l'exposition des identifiants. Consultez Manage variables.

   

5. Cliquez sur Confirm.

Le catalogue apparaît sur la page Catalog List.

Création d'un catalogue StarRocks avec Flink SQL

Dans l'éditeur SQL de la page Scripts, saisissez une instruction CREATE CATALOG, sélectionnez-la, puis cliquez sur Run à gauche.

CREATE CATALOG <catalogname> WITH (
  'type' = 'starrocks',
  'endpoint' = '<ip>:<port>',
  'username' = '<userName>',
  'password' = '<password>',
  'dbname' = '<dbname>'
);

Les options de configuration varient selon votre version VVR.

Lecture des données d'une table StarRocks

INSERT INTO ${other_sink_table}
SELECT ...
FROM `${catalog_name}`.`${db_name}`.`${table_name}`

INSERT INTO ${other_sink_table}
SELECT ...
FROM `${catalog_name}`.`${db_name}`.`${table_name}`
    /*+
        OPTIONS('connector' = 'starrocks', 'jdbc-url' = 'jdbc:mysql://ip:port', 'scan-url' = 'ip:port')
    */

Écriture des données dans une table StarRocks

INSERT INTO `${catalog_name}`.`${db_name}`.`${table_name}`
SELECT ...
FROM ${other_source_table}

INSERT INTO `${catalog_name}`.`${db_name}`.`${table_name}`
    /*+
        OPTIONS('connector' = 'starrocks', 'jdbc-url' = 'jdbc:mysql://ip:port', 'load-url' = 'ip:port', 'sink.buffer-flush.interval-ms' = '5000', 'sink.properties.row_delimiter' = '\x02', 'sink.properties.column_separator' = '\x01')
    */
SELECT ...
FROM ${other_source_table}

Utilisation de CTAS ou CDAS pour écrire dans StarRocks

CTAS (CREATE TABLE AS SELECT) et CDAS (CREATE DATABASE AS DATABASE) vous permettent de créer des tables ou des bases de données StarRocks à partir de sources existantes en une seule instruction.

USE CATALOG sr_catalog;

CREATE TABLE IF NOT EXISTS `${table_name}`
WITH (
  ...
) AS TABLE ${other_source_table};

CREATE DATABASE IF NOT EXISTS `${db_name}`
WITH (
  ...
) AS DATABASE ${other_source_database};

Pour une procédure complète, consultez Ingest data from MySQL to StarRocks with Flink.

Suppression d'un catalogue StarRocks via la console

1. Connectez-vous à la console Realtime Compute for Apache Flink. Recherchez l'espace de travail souhaité et cliquez sur Console dans la colonne Actions.

2. Dans le volet de navigation de gauche, cliquez sur Catalogs.

3. Sur la page Catalog List, localisez le catalogue et cliquez sur Delete dans la colonne Actions.

4. Dans la boîte de dialogue de confirmation, cliquez sur Delete.

Le catalogue est retiré du volet Catalogs dans la navigation de gauche.

Suppression d'un catalogue StarRocks avec Flink SQL

Dans l'éditeur SQL de la page Scripts, saisissez l'instruction suivante, faites un clic droit dessus, puis sélectionnez Run.

DROP CATALOG `<catalog name>`;

Remplacez <catalog name> par le nom du catalogue que vous souhaitez supprimer.

Après l'exécution de l'instruction, vérifiez que le catalogue a bien été supprimé en consultant le volet Catalogs dans la navigation de gauche.