更新时间：2024-07-01 GMT+08:00
Redis源表
功能描述
创建source流从Redis获取数据，作为作业的输入数据。
前提条件
要建立增强型跨源连接，且用户可以根据实际所需设置相应安全组规则。
- 如何建立增强型跨源连接，请参考《数据湖探索用户指南》中增强型跨源连接章节。
- 如何设置安全组规则，请参见《虚拟私有云用户指南》中“安全组”章节。
语法格式
1 2 3 4 5 6 7 8 9 10 |
create table dwsSource ( attr_name attr_type (',' attr_name attr_type)* (',' watermark for rowtime_column_name as watermark-strategy_expression) ) with ( 'connector.type' = 'redis', 'connector.host' = '', 'connector.port' = '' ); |
参数说明
|
参数 |
是否必选 |
说明 |
|---|---|---|
|
connector.type |
是 |
connector类型，对于redis，需配置为'redis'。 |
|
connector.host |
是 |
redis连接地址。 |
|
connector.port |
是 |
redis连接端口。 |
|
connector.password |
否 |
redis认证密码。 |
|
connector.deploy-mode |
否 |
redis部署模式，支持standalone/cluster，默认standalone。 |
|
connector.table-name |
否 |
table存储模式下必配，redis中存储表名。在table存储模式下，数据将以hash类型存储到redis，其中key为：${table-name}:${ext-key}，field名为列名。
说明：
table存储模式：将connector.table-name、connector.key-column作为redis的key。redis的hash类型，每个key对应一个hashmap，hashmap的hashkey为源表的字段名，hashvalue为源表的字段值。 |
|
connector.use-internal-schema |
否 |
table存储模式下可配置，是否使用redis中已存在schema，默认为false。 |
|
connector.key-column |
否 |
table存储模式下可配置，将该字段值作为redis中的ext-key，未配置时，ext-key为生成的uuid。 |
示例
从Redis中读取数据。
create table redisSource( car_id STRING, car_owner STRING, car_brand STRING, car_speed INT ) with ( 'connector.type' = 'redis', 'connector.host' = 'xx.xx.xx.xx', 'connector.port' = '6379', 'connector.password' = 'xx', 'connector.table-name' = 'car_info' );
父主题： 创建源表
