[Question] Flet + RabbitMQ(aio_pika) + FastApi

[onyxPC]

Question

Hello.

How to send a message(message.body) from the process_message function to ft.text() functions of main?

Как отправить тело сообщения(message.body) из функции process_message в ft.Text() функции main ?

Thank you.
Дзякую.

Code sample

import logging
import asyncio

from contextlib import asynccontextmanager
from typing import Optional
from dataclasses import dataclass

import flet as ft
import flet_fastapi
from fastapi import FastAPI


from aio_pika import connect_robust, Message
from aio_pika.abc import AbstractRobustConnection, AbstractRobustChannel, AbstractRobustQueue, AbstractIncomingMessage
from aio_pika import logger

logger.setLevel(logging.ERROR)

RABBITMQ_DEFAULT_USER: str = 'guest'
RABBITMQ_DEFAULT_PASS: str = 'guest'
RABBITMQ_LOCAL_HOST_NAME: str = 'localhost'
RABBITMQ_LOCAL_PORT: int = 5672
RABBITMQ_QUEUE: str = 'test_queue'

RABBIT_URL = f'amqp://{RABBITMQ_DEFAULT_USER}:' \
             f'{RABBITMQ_DEFAULT_PASS}@' \
             f'{RABBITMQ_LOCAL_HOST_NAME}:' \
             f'{RABBITMQ_LOCAL_PORT}/'

@dataclass
class RabbitConnection:
    _connection: Optional[AbstractRobustConnection] = None
    _channel: Optional[AbstractRobustChannel] = None
    _queue: Optional[AbstractRobustQueue] = None
    
    async def disconnect(self) -> None:
        if self._channel and not self._channel.is_closed:
            await self._channel.close()
        if self._connection and not self._connection.is_closed:
            await self._connection.close()
        self._connection = None
        self._channel = None
        print("Rabbit disconnect")

    async def connect(self) -> None:
        try:
            self._connection = await connect_robust(RABBIT_URL)
            self._channel = await self._connection.channel(publisher_confirms=False)
            self._queue = await self._channel.declare_queue('test', auto_delete=True)
            await self._queue.bind('test', 'test')
            await self._queue.consume(self.process_message)
            print("Rabbit connect")
        except Exception as e:
            print(e)
            await self.disconnect()
    
    async def process_message(connection: AbstractRobustConnection, message: AbstractIncomingMessage) -> None:
        async with message.process():
            print(" [x] Received message %r" % message)
            print("Message body is: %r" % message.body)
            await asyncio.sleep(30)

rabbit_connection = RabbitConnection()

@asynccontextmanager
async def lifespan(app: FastAPI):
    await rabbit_connection.connect()
    await flet_fastapi.app_manager.start()
    yield
    await flet_fastapi.app_manager.shutdown()
    await rabbit_connection.disconnect()

app = FastAPI(lifespan=lifespan)

async def main(page: ft.Page):
    text = ft.Text("Hello, async world!")
    await page.add_async(text)
    
app.mount("/", flet_fastapi.app(main))

Error message

No response

------------------------------------------------------

• I have searched for answers to my question both in the issues and in previous discussions.