Lindorm:Uso de Flink para acceder a LindormTable

Determinación del tipo de tabla al que se accederá

En Lindorm, puede utilizar Lindorm SQL para determinar el tipo de LindormTable al que necesita acceder un trabajo de Flink en desarrollo:

1. Utilice lindorm-cli (o directamente Lindorm Insight o DMS) para conectarse al motor de tablas anchas de Lindorm.

2. Ejecute la siguiente sentencia SQL para comprobar el atributo IS_HBASE_LIKE de la tabla.

   • Si el valor del atributo es TRUE, la tabla es una tabla HBase.

   • Si el valor del atributo es FALSE, la tabla es una tabla SQL.

   SHOW TABLE VARIABLES FROM table_name LIKE 'IS_HBASE_LIKE';

Elección del tipo de conector

Según la versión del producto Flink que haya seleccionado, decida qué conector utilizar para acceder a LindormTable.

Obtención de la información de conexión de LindormTable

• Escenario 1: Uso del conector HBase de código abierto o del conector de base de datos multimodelo nativa de la nube Lindorm. En este escenario, la dirección de conexión debe ser la dirección de acceso de la API de Java para HBase (VPC) del motor de tablas anchas. En la página de detalles de la instancia de Lindorm, haga clic en Database connections en el menú lateral izquierdo y seleccione la pestaña Wide Table Engine. En el área Connect through HBase-compatible address, obtenga la dirección VPC con el formato ld-<instance-ID>-proxy-lindorm.lindorm.rds.aliyuncs.com:30020. En el área Connect through MySQL-compatible address, obtenga la dirección compatible con MySQL con el formato ld-<instance-ID>-proxy-sql-lindorm.lindorm.rds.aliyuncs.com:33060.

• Escenario 2: Uso del conector JDBC. En este escenario, la dirección de conexión debe ser la dirección compatible con MySQL (VPC) del motor de tablas anchas. En la página de detalles de la instancia de Lindorm, haga clic en Database connections en el panel de navegación izquierdo y seleccione la pestaña Wide Table Engine. En el área Connect through HBase-compatible address, puede ver la dirección VPC de la API de Java para HBase (con el formato ld-<instance-ID>-proxy-lindorm.lindorm.rds.aliyuncs.com:30020).

Requisitos previos

• Desarrollo de un trabajo que utiliza Flink de la comunidad para acceder a LindormTable

  • Para usar el conector HBase de código abierto y acceder a LindormTable, asegúrese de que el motor de tablas anchas sea de la versión 2.4.3 o posterior.

  • Para usar el conector JDBC de código abierto y acceder a LindormTable, asegúrese de que el motor de tablas anchas sea de la versión 2.6.5.2 o posterior, y de haber completado Enable the MySQL compatibility feature.

  • Para obtener información sobre cómo ver o actualizar la versión actual, consulte LindormTable release notes y Upgrade the minor engine version of a Lindorm instance.

• Si utiliza Realtime Compute for Apache Flink para desarrollar un trabajo que acceda a LindormTable, no existe ninguna restricción de versión para el motor de tablas anchas.

• Asegúrese de que el entorno donde se encuentra el clúster de Flink tenga conectividad de red con la instancia de Lindorm, y de que las direcciones IP del cliente estén agregadas a la lista blanca de Lindorm. Para obtener información sobre cómo agregar direcciones IP a la lista blanca, consulte Configure a whitelist.

Desarrollo de trabajos con Flink de la comunidad

# Create Flink table and start the job
CREATE TABLE source_table(
    c1 INT,
    c2 STRING
) WITH (
  'connector' = 'datagen',
  'rows-per-second' = '2',
  'fields.c2.length' = '5',
  'fields.c1.min' = '1',
  'fields.c1.max' = '100'
);

CREATE TABLE sink_table(
    c1 INT,
    c2 STRING
) WITH (
    'connector' = 'jdbc',
    'url' = 'jdbc:mysql://ld-xxxxx-proxy-lindorm.lindorm.rds.aliyuncs.com:33060/default?sslMode=disabled&allowPublicKeyRetrieval=true&useServerPrepStmts=true&useLocalSessionState=true&rewriteBatchedStatements=true&cachePrepStmts=true&prepStmtCacheSize=300&prepStmtCacheSqlLimit=50000000',
    'username' = 'root',
    'password' = 'root',
    'table-name' = 'testflink'
);

INSERT INTO sink_table SELECT * FROM source_table;

Desarrollo de trabajos con Realtime Compute for Apache Flink