Lindorm:Flink ile LindormTable'a Erişim

Erişilecek Tablo Türünü Belirleme

Geliştirme aşamasındaki bir Flink görevinin erişmesi gereken LindormTable türünü belirlemek için Lindorm SQL'i kullanabilirsiniz:

1. Geniş tablo motoruna bağlanmak için lindorm-cli (veya doğrudan Lindorm Insight ya da DMS) kullanın.

2. Tablonun IS_HBASE_LIKE niteliğini kontrol etmek için aşağıdaki SQL ifadesini çalıştırın.

   • Nitelik değeri TRUE ise tablo bir HBase tablosudur.

   • Nitelik değeri FALSE ise tablo bir SQL tablosudur.

   SHOW TABLE VARIABLES FROM table_name LIKE 'IS_HBASE_LIKE';

Bağlayıcı Türünü Seçme

Seçtiğiniz Flink ürün formuna göre LindormTable'a erişmek için hangi bağlayıcıyı kullanacağınıza karar verin.

LindormTable Bağlantı Bilgilerini Edinme

• Senaryo 1: Açık kaynaklı HBase bağlayıcısını veya cloud-native çok modelli veritabanı Lindorm bağlayıcısını kullanma

  Bu senaryoda bağlantı adresi, geniş tablo motorunun HBase Java API erişim adresi (VPC) olmalıdır.

  Lindorm örnek detayları sayfasında sol menüden Database connections seçeneğine tıklayın ve Wide Table Engine sekmesini seçin. Connect through HBase-compatible address alanında ld-<instance-ID>-proxy-lindorm.lindorm.rds.aliyuncs.com:30020 biçimindeki VPC adresini edinin. Connect through MySQL-compatible address alanında ld-<instance-ID>-proxy-sql-lindorm.lindorm.rds.aliyuncs.com:33060 biçimindeki MySQL uyumlu adresi edinin.

• Senaryo 2: JDBC bağlayıcısını kullanma

  Bu senaryoda bağlantı adresi, geniş tablo motorunun MySQL uyumlu adresi (VPC) olmalıdır.

  Lindorm örnek detayları sayfasında sol gezinme bölmesinden Database connections seçeneğine tıklayın ve Wide Table Engine sekmesini seçin. Connect through HBase-compatible address alanında HBase Java API'nin VPC adresini (ld-<instance-ID>-proxy-lindorm.rds.aliyuncs.com:30020 biçiminde) görüntüleyebilirsiniz.

Ön Koşullar

• Topluluk sürümü Flink kullanarak LindormTable'a erişen bir görev geliştirme

  • LindormTable'a erişmek için açık kaynaklı HBase bağlayıcısını kullanacaksanız geniş tablo motoru sürümünün 2,4,3 veya üzeri olduğundan emin olun.

  • LindormTable'a erişmek için açık kaynaklı JDBC bağlayıcısını kullanacaksanız geniş tablo motoru sürümünün 2,6,5,2 veya üzeri olduğundan ve MySQL uyumluluk özelliğini etkinleştirdiğinizden emin olun.

  • Mevcut sürümü görüntüleme veya yükseltme hakkında bilgi için bkz. LindormTable sürüm notları ve Lindorm örneğinin küçük motor sürümünü yükseltme.

• LindormTable'a erişen bir görev geliştirmek için Realtime Compute for Apache Flink kullanıyorsanız geniş tablo motoru üzerinde herhangi bir sürüm kısıtlaması yoktur.

• Flink kümesinin bulunduğu ortamın Lindorm örneği ile ağ bağlantısına sahip olduğundan ve istemci IP adreslerinin Lindorm izin listesine eklendiğinden emin olun. IP adreslerini izin listesine ekleme hakkında bilgi için bkz. İzin listesi yapılandırma.

Topluluk Sürümü Flink ile Görev Geliştirme

# 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;

Realtime Compute for Apache Flink ile Görev Geliştirme