вопросов, на которые, надеюсь, вы знаете ответы:
Как правильнее создавать именованную очередь:
1) как в примере вызывая netbox в коде Lua
2) создать роль, в котором будет инициализироваться именованная очередь. И эту роль впоследствии добавлять только для одного шарда? Или на все сразу цеплять?
3) в init.lua, где находится cartridge.cfg, создавать очередь путём
local sharded_queue_api = require('sharded_queue.api')
sharded_queue_api.create_tube('name 1')
и дальше уже с мастеров обращаться к созданной очереди
____
Направьте, пожалуйста, на верный путь :) ☺️
1) При написании приложения на Картридже весь код бизнес-логики у вас будет располагаться в ролях или в модулях, которые в конечном счёте инициализируются из ролей. 2) Так что код, работающий с API sharded-queue, логично размещать на тех же нодах, где включена роль sharded_queue.api (или добавлять эту роль в dependencies). Вызовы netbox при этом будут не нужны 3) Создать очередь можно прямо в конфиге кластера. См. ридми
Спасибо!
Обсуждают сегодня