Queue Manager

Общее

Простой менеджер очереди для редис который умеет ставить в очередь по уникальным параметрам запроса.

Параметры

• size - размер очереди
• unique_keys - список путей до уникальных ключей в параметрах (формата ‘method_params.account_id’)
• wait_time - максимальное время ожидание постановки задачи в очередь (по умолчанию 5 секунд)

Примеры

Пример 1

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

@redis_queue(5, ['refresh_token'])
def google_analytics_nc(META: MetaApp, version, refresh_token, method, method_params, data_format=None, http_response=None):

Пример 2

Использование в коде с другим временем ожидания

@redis_queue(5, ['refresh_token'], 10)
def google_analytics_nc(META: MetaApp, version, refresh_token, method, method_params, data_format=None, http_response=None):