Я разработал приложение Python tornado, которое состоит из нескольких компонентов: 1) RabbitMq 2) Сеанс на удаленный сервер, который запрашивает обработчик 3) Приложение Tornado
в начале я запускаю сеанс Rabbitmq с помощью pika, затем я подключаюсь к удаленному серверу с объектом Session. Я сохранил кролика и сессию в настройках сервера торнадо:
def make_app(cfg : DictConfig=None):
LOGGER.info("Creating Application")
settings = app_settings()
app_setup_data = setup_app(cfg)
if app_setup_data is None:
return None
return tornado.web.Application([
(r"/", MainHandler),
(r"/rabbit/([^/]+)?", RabbitManagment, dict(rabbit_cfg=cfg.rabbit)),
(r"/rabbit", RabbitManagmentTest, dict(rabbit_cfg=cfg.rabbit))
], settings=settings, pubsubs=app_setup_data.get('rabbit'), my_srv=app_setup_data.get('remote_server'))
проблема в том, что когда я получил запрос от пользователя rabbitmq, мне нужно принять запрос и отправить его на сервер через сессию. Я не хочу создавать сеанс для каждого сообщения в кролике, и я хочу сохранить свой существующий сеанс. проблема в том, что в контексте кролика у меня нет сеанса, который хранится в настройках торнадо. Как я могу использовать сеанс удаленного сервера от потребителя кролика?
Спасибо!