云原生多模数据库 Lindorm 通过Flink访问Lindorm

By | 2021年4月22日

使用HBase API的用户,支持通过阿里云实时计算服务(Apache Flink)访问Lindorm。用户可以把Lindorm中的表当做Flink 中的维表或者结果表,其使用方式与HBase一致,具体参见阿里云实时计算服务帮助中的创建云数据库HBase版结果表创建云数据库 HBase版维表

在使用Lindorm的表作为Flink的维表或者结果表时,创建表的DDL语句时,需要使用连接地址。Flink访问Lindorm使用的是Java API访问地址。用户名密码默认为root,root。如果使用新创建的用户,请确保该用户拥有访问与Flink关联的表的读写权限,详见用户和ACL管理。示例的DDL语句如下:

创建维表

1. CREATE TABLE Lindorm (
2.   `key` varchar,
3.    `name` varchar,
4.    PRIMARY KEY (`key`), -- Lindorm中的rowkey字段。
5.    PERIOD FOR SYSTEM_TIME --维表标识。
6.   ) with (
7.    TYPE = 'cloudLindorm',
8.    endpoint = 'host:port',-- Lindorm的Java API访问地址
9.    columnFamily = 'xxxxxx',
10.    userName  = 'root', -- 用户名
11.    password = 'root', -- 密码
12.    tableName = 'xxxxxx'
13. );

创建结果表

1. create table liuxd_user_behavior_test_front (
2.    row_key varchar,
3.    from_topic varchar,
4.    origin_data varchar,
5.    record_create_time varchar,
6.    primary key (row_key)) 
7. with (
8.    type = 'cloudLindorm',
9.    endpoint = 'host:port', -- Lindorm的Java API访问地址
10.    userName  = 'root', -- 用户名
11.    password = 'root', -- 密码
12.    columnFamily = '<yourColumnFamily>',
13.    tableName = '<yourTableName>',
14.    batchSize = '500'
15. )

网络打通

如果使用共享版的Flink集群,请参见阿里云实时计算的帮助文档VPC访问授权进行VPC的网络打通。如果使用独立的Flink集群,请确保Flink集群和Lindorm集群在同一个VPC下。否则只能用公网访问地址链接Lindorm。无论是哪种链接方式,都需要确保Flink的机器的IP加到Lindorm实例的白名单中(参见设置白名单)。

请关注公众号获取更多资料

发表回复

您的电子邮箱地址不会被公开。 必填项已用*标注