/
woodpecker86
/
cosmic-python-code
Обзор
Документация
Войти
/
woodpecker86
/
cosmic-python-code
Код
Запросы
0
Пакеты
0
Релизы
0
CI/CD
Аналитика
Безопасность
master
src/allocation/entrypoints/redis_eventconsumer.py
31 строка
724 B
Harry
logging.info needs backport
01 мар 2024, 18:05
01 мар 2024, 18:05
bb51578
Код
Авторство
О чём код?
import json import logging import redis from allocation import bootstrap, config from allocation.domain import commands logger = logging.getLogger(__name__) r = redis.Redis(**config.get_redis_host_and_port()) def main(): logger.info("Redis pubsub starting") bus = bootstrap.bootstrap() pubsub = r.pubsub(ignore_subscribe_messages=True) pubsub.subscribe("change_batch_quantity") for m in pubsub.listen(): handle_change_batch_quantity(m, bus) def handle_change_batch_quantity(m, bus): logger.info("handling %s", m) data = json.loads(m["data"]) cmd = commands.ChangeBatchQuantity(ref=data["batchref"], qty=data["qty"]) bus.handle(cmd) if __name__ == "__main__": main()