Redis

Этот движок позволяет интегрировать ClickHouse с Redis. Так как Redis использует модель kv, мы настоятельно рекомендуем выполнять запросы только по точечному принципу, например, where k=xx или 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);

Параметры движка

• host:port — адрес сервера Redis, можно игнорировать порт, по умолчанию будет использован порт Redis 6379.
• db_index — индекс базы данных Redis в диапазоне от 0 до 15, по умолчанию 0.
• password — пароль пользователя, по умолчанию пустая строка.
• pool_size — максимальный размер пула подключений Redis, по умолчанию 16.
• primary_key_name - любое имя колонки в списке колонок.

Сериализация

PRIMARY KEY поддерживает только одну колонку. Первичный ключ будет сериализован в бинарном формате в качестве ключа Redis. Колонки, отличные от первичного ключа, будут сериализованы в бинарном формате в качестве значения Redis в соответствующем порядке.

Аргументы также могут передаваться с помощью именованных коллекций. В этом случае host и port должны быть указаны отдельно. Этот подход рекомендуется для производственной среды. В данный момент все параметры, переданные через именованные коллекции в Redis, являются обязательными.

Фильтрация

Запросы с key equals или in filtering будут оптимизированы в многократный поиск ключей в Redis. Если запросы без фильтрации ключа, произойдет полный скан таблицы, что является тяжёлой операцией.

Пример использования

Создайте таблицу в ClickHouse, используя движок Redis с простыми аргументами:

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

Или используя именованные коллекции:

<named_collections>
    <redis_creds>
        <host>localhost</host>
        <port>6379</port>
        <password>****</password>
        <pool_size>16</pool_size>
        <db_index>s0</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);

Вставка:

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 │
└─────┴────┴────┴────┘

Обновление:

Обратите внимание, что первичный ключ не может быть обновлён.

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

Удаление:

ALTER TABLE redis_table DELETE WHERE key='1';

Очищение:

Асинхронно очищает базу данных Redis. Также Truncate поддерживает режим SYNC.

TRUNCATE TABLE redis_table SYNC;

Соединение:

Соединение с другими таблицами.

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

Ограничения

Двигатель Redis также поддерживает сканирующие запросы, такие как where k > xx, но имеет некоторые ограничения:

1. Сканирующий запрос может производить некоторые дублирующиеся ключи в очень редком случае, когда происходит пере hashed. См. детали в Redis Scan.
2. Во время сканирования ключи могут быть созданы и удалены, поэтому результирующий набор данных не может представлять собой валидную точку во времени.