Motor de tabela Redis

Este motor permite integrar o ClickHouse ao Redis. Como o Redis adota o modelo chave-valor, recomendamos fortemente que ele seja consultado apenas de forma pontual, como em where k=xx ou where k in (xx, xx).

CREATE TABLE [IF NOT EXISTS] [db.]table_name
(
    name1 [type1],
    name2 [type2],
    ...
) ENGINE = Redis({host:port[, db_index[, password[, pool_size]]] | named_collection[, option=value [,..]] })
PRIMARY KEY(primary_key_name);

Parâmetros do motor

• host:port — Endereço do servidor Redis; você pode ignorar a porta, e a porta padrão do Redis, 6379, será usada.
• db_index — Índice do banco de dados Redis, de 0 a 15; o padrão é 0.
• password — Senha do usuário; o padrão é uma string vazia.
• pool_size — Tamanho máximo do pool de conexões do Redis; o padrão é 16.
• primary_key_name - qualquer nome de coluna na lista de colunas.

Os argumentos também podem ser passados usando coleções nomeadas. Nesse caso, host e port devem ser especificados separadamente. Essa abordagem é recomendada para ambientes de produção. No momento, todos os parâmetros passados ao Redis usando coleções nomeadas são obrigatórios.

Crie uma tabela no ClickHouse usando o motor Redis com argumentos simples:

CREATE TABLE redis_table
(
    `key` String,
    `v1` UInt32,
    `v2` String,
    `v3` Float32
)
ENGINE = Redis('redis1:6379') PRIMARY KEY(key);

Ou usando coleções nomeadas:

<named_collections>
    <redis_creds>
        <host>localhost</host>
        <port>6379</port>
        <password>****</password>
        <pool_size>16</pool_size>
        <db_index>0</db_index>
    </redis_creds>
</named_collections>

CREATE TABLE redis_table
(
    `key` String,
    `v1` UInt32,
    `v2` String,
    `v3` Float32
)
ENGINE = Redis(redis_creds) PRIMARY KEY(key);

Inserção:

INSERT INTO redis_table VALUES('1', 1, '1', 1.0), ('2', 2, '2', 2.0);

SELECT COUNT(*) FROM redis_table;

┌─count()─┐
│       2 │
└─────────┘

SELECT * FROM redis_table WHERE key='1';

┌─key─┬─v1─┬─v2─┬─v3─┐
│ 1   │  1 │ 1  │  1 │
└─────┴────┴────┴────┘

SELECT * FROM redis_table WHERE v1=2;

┌─key─┬─v1─┬─v2─┬─v3─┐
│ 2   │  2 │ 2  │  2 │
└─────┴────┴────┴────┘

Atualização:

Observe que não é possível atualizar a chave primária.

ALTER TABLE redis_table UPDATE v1=2 WHERE key='1';

Excluir:

ALTER TABLE redis_table DELETE WHERE key='1';

Truncate:

Executa o flush assíncrono do banco de dados do Redis. Além disso, Truncate também oferece suporte ao modo SYNC.

TRUNCATE TABLE redis_table SYNC;

Join:

Junção com outras tabelas.

SELECT * FROM redis_table JOIN merge_tree_table ON merge_tree_table.key=redis_table.key;

O motor Redis também oferece suporte a consultas de varredura, como where k > xx, mas tem algumas limitações:

1. Em casos muito raros, uma consulta de varredura pode gerar chaves duplicadas durante o rehash. Veja os detalhes em Redis Scan.
2. Durante a varredura, chaves podem ser criadas e excluídas, portanto o conjunto de dados resultante não representa um ponto válido no tempo.