tencent cloud

-- The first column is "key" and the second column "value". The Redis command is "set key value".
CREATE TABLE `redis_set_sink_table` (  
 `key` STRING,
 `value` STRING
) WITH (
  'connector' = 'redis',     -- The connector (Redis) to use.
  'command' = 'set',         -- The SET command.
  'nodes' = '<host>:<port>', -- The Redis server connection address.
  'password' = '<password>', 
  'database' = '<database>'  
);

-- The first column is "key" and the second column "value". The Redis command is "Ipush key value".
CREATE TABLE `redis_lpush_sink_table` (  
 `key` STRING,
 `value` STRING
) WITH (
  'connector' = 'redis',     -- The connector (Redis) to use.
  'command' = 'lpush',       -- The LPUSH command.
  'nodes' = '<host>:<port>', -- The Redis server connection address.
  'password' = '<password>', 
  'database' = '<database>'  
);


-- The first column is "key" and the second column "value". The Redis command is "sadd key value".
CREATE TABLE `redis_sadd_sink_table` (  
 `key`   STRING,
 `value` STRING
) WITH (
  'connector' = 'redis',     -- The connector (Redis) to use.
  'command' = 'sadd',        -- The SADD command
  'nodes' = '<host>:<port>', -- The Redis server connection address.
  'password' = '<password>', 
  'database' = '<database>'  
);


-- The first column is "hash_key" and the second column "hash_value". The Redis command is "hset key hash_key hash_value".
CREATE TABLE `redis_hset_sink_table` (  
 `hash_key`   STRING,
 `hash_value` STRING
) WITH (
  'connector' = 'redis',     -- The connector (Redis) to use.
  'command' = 'hset',        -- The HSET command.
  'nodes' = '<host>:<port>', -- The Redis server connection address.
  'password' = '<password>', 
  'database' = '<database>', 
  'additional-key' = '<key>' -- The hash key.
);


-- The first column is "key", the second column "hash_key", and the third column "hash_value". The Redis command is "hset key hash_key hash_value".
CREATE TABLE `redis_hset_sink_table` (  
`key`        STRING,
`hash_key`   STRING,
`hash_value` STRING
) WITH (
'connector' = 'redis',     -- The connector (Redis) to use.
'command' = 'hset',        -- The HSET command.
'nodes' = '<host>:<port>', -- The Redis server connection address.
'password' = '<password>', 
'database' = '<database>'
);


-- The first column is "key", the second column "hash_key", and the third column "hash_value". The Redis command to insert data is "hmset key hash_key hash_value".
CREATE TABLE `redis_hmset_sink_table` (
  `key`        STRING,
  `fieldKey`   STRING,
  `fieldValue` STRING
) WITH (
  'connector' = 'redis',     -- The connector (Redis) to use.
  'command' = 'hmset',       -- The HMSET command.
  'nodes' = '<host>:<port>', -- The Redis server connection address.
  'password' = '<password>'
);

-- The first column is "hash_key" and the second column "hash_value". The ‌Redis command is "zadd key value score".
CREATE TABLE `redis_zadd_sink_table` (  
 `value` STRING,
 `score` DOUBLE
) WITH (
  'connector' = 'redis',     -- The connector (Redis) to use.
  'command' = 'zadd',        -- The ZADD command.
  'nodes' = '<host>:<port>', -- The Redis server connection address.
  'password' = '<password>', 
  'database' = '<database>', 
  'additional-key' = '<key>' -- The sorted set key.
);


  -- The first column is "key", the second column "value", and the third column "score". The ‌Redis command is "zadd key value score".
CREATE TABLE `redis_zadd_sink_table` (  
`key` STRING,
`value` STRING,
`score` DOUBLE
) WITH (
'connector' = 'redis',     -- The connector (Redis) to use.
'command' = 'zadd',        -- The ZADD command.
'nodes' = '<host>:<port>', -- The Redis server connection address.
'password' = '<password>', 
'database' = '<database>', 
);

CREATE TABLE `redis_dimension_table` (  
 `key`   STRING,
 `value` STRING
) WITH (
  'connector' = 'redis',          
  'command' = 'get',              -- The GET command.
  'nodes' = '<host>:<port>',     -- The Redis server connection address. For a cluster mode, separate nodes by comma.
  'lookup.cache.max-rows' = '500', -- The maximum number of data records allowed in the Lookup Cache.
  'lookup.cache.ttl' = '10 min', -- The maximum cache time of each record.
  'lookup.max-retries' = '5', -- The maximum number of retries after query failure.
  -- 'password' = '<password>',   -- The password (optional).
  -- 'database' = '<database>',   -- The database (optional), which defaults to `0`.
  -- 'redis-mode' = 'standalone' -- The Redis mode (optional), which defaults to `standalone`. (Valid values: `standalone` and `cluster`.)     
);

CREATE TABLE datagen_source_table ( 
    id INT, 
    name STRING 
) WITH ( 
   'connector' = 'datagen',
   'rows-per-second'='1'  -- The number of data records generated per second.
);

CREATE TABLE `redis_set_sink_table` (  
 `key` STRING,
 `value` STRING
) WITH (
  'connector' = 'redis',     -- The connector (Redis) to use.
  'command' = 'set',         -- The SET command.
  'nodes' = '127.0.0.1:8121', -- The Redis server connection address.
  'password' = '<password>', 
  'database' = '0'  
);
insert into redis_set_sink_table select cast(id as string), name from datagen_source_table;