Tarantool Queue Image

Введение

Образ с реализацией пакетной обработки очередей на базе Tarantool.

Доступные типы очередей fifo, fifo_replace, fifo_skip, fifottl, utube, utubettl.

Установка

Шаг 1: Загрузка

docker pull registry.marfa-tech.net/marfatech/tarantool-queue:latest

Эта команда подразумевает что Docker установлен и доступен глобально.

Шаг 2: Подключение образа

После подключите образ в docker-compose.yaml добавив его для контейнера tarantool вашего проекта:

services:
    # ...
    tarantool:
        image: registry.marfa-tech.net/marfatech/tarantool-queue:latest
        ports:
            - 3301:3301
        user: tarantool
        volumes:
            - ./.data/tarantool:/var/lib/tarantool
        environment:
            TARANTOOL_PORT: ${TARANTOOL_PORT}
            TARANTOOL_USER_NAME: ${TARANTOOL_USER_NAME}
            TARANTOOL_USER_PASSWORD: ${TARANTOOL_USER_PASSWORD}
    # ...
}

Использование

Выбрать подходящий коннектор для работы с очередями.

Перед работой с очередью необходимо инициализировать tube:

init_tube(QUEUE_NAME, QUEUE_TYPE)

Посредством вызова ниже перечисленных методов предполагается работа с элементами из очереди:

queue.tube.QUEUE_NAME:put_list(data_list)
queue.tube.QUEUE_NAME:ack_list(id_list)
queue.tube.QUEUE_NAME:take_list(limit, timeout)
queue.stats(QUEUE_NAME)

Реализация типов очередей fifo, fifo_replace, fifo_skip, fifottl, utube, utubettl.

Предполагается наличие базовых знаний языка Lua.

Разработка

Авторизоваться

docker login registry.marfa-tech.net -u XXX -p XXX

Пересобрать образ

docker build -t tarantool-queue .

Создание тега

docker tag tarantool-queue:latest registry.marfa-tech.net/marfatech/tarantool-queue:latest

Отправить изменения

docker push registry.marfa-tech.net/marfatech/tarantool-queue

Лицензия