а тут он зачем? ты рекламу этого чата в своем канале постишь?

Привет всем, может кто нибудь подсказать
Python/RabbitMQ
Есть у меня вот такой просто консьюмер  

class VideoCreatorWorker(Thread):
    def __init__(self, db_connect, *args, **kwargs):
        super(VideoCreatorWorker, self).__init__(*args, **kwargs)

        self.__credentials = pika.PlainCredentials('user', 'user')
        self.__host = 'localhost'
        self.__port = 5672
        self.__virtual_host = '/'
        self.__name_queue = 'task_queue'

    def callback(self, channel, method, properties, body):
        print("{} received '{}'".format(self.name, body))

    def run(self):
        connection = pika.BlockingConnection(
            pika.ConnectionParameters(
                host=self.__host, 
                port=self.__port,
                virtual_host=self.__virtual_host,
                credentials=self.__credentials
            )
        )
        channel = connection.channel()
        channel.basic_consume(self.__name_queue, 
            on_message_callback=self.callback,
        )

        channel.start_consuming()

И вот такой поставщик

async def render(self, 
        components_id:int,
        background_tasks: BackgroundTasks,
        videos_components:VideosComponentRepository,
        video_repository: VideoRepository):
        
        videos_components_obj = await videos_components.get_by_id(components_id)

        new_video = VideoIn(
            name=videos_components_obj.name,
            video_components_id=videos_components_obj.id,
            owner_id=videos_components_obj.owner_id,
        )
        new_video = await video_repository.create(new_video)

        body = {
            'video_components':jsonable_encoder(videos_components_obj),
            'video_id':new_video.id
        }
        
        credentials = pika.PlainCredentials('user', 'user')

        connection = pika.BlockingConnection(
                pika.ConnectionParameters(
                host='localhost', 
                port=5672,
                virtual_host='/',
                credentials=credentials
            )
        )

        channel = connection.channel()
        channel.queue_declare(queue='task_queue', durable=True)

        channel.basic_publish(
            exchange='',
            routing_key='task_queue',
            body = json.dumps(body),
            properties=pika.BasicProperties(
                delivery_mode=2,  # make message persistent
            ),
        )
        connection.close()

Как мне в поставщике узнать что отправленная им, конкретная задача, выполнилась ?

class VideoCreatorWorker(Thread):
    def __init__(self, db_connect, *args, **kwargs):
        super(VideoCreatorWorker, self).__init__(*args, **kwargs)

        self.__credentials = pika.PlainCredentials('user', 'user')
        self.__host = 'localhost'
        self.__port = 5672
        self.__virtual_host = '/'
        self.__name_queue = 'task_queue'

    def callback(self, channel, method, properties, body):
        print("{} received '{}'".format(self.name, body))

    def run(self):
        connection = pika.BlockingConnection(
            pika.ConnectionParameters(
                host=self.__host, 
                port=self.__port,
                virtual_host=self.__virtual_host,
                credentials=self.__credentials
            )
        )
        channel = connection.channel()
        channel.basic_consume(self.__name_queue, 
            on_message_callback=self.callback,
        )

        channel.start_consuming()

async def render(self, 
        components_id:int,
        background_tasks: BackgroundTasks,
        videos_components:VideosComponentRepository,
        video_repository: VideoRepository):
        
        videos_components_obj = await videos_components.get_by_id(components_id)

        new_video = VideoIn(
            name=videos_components_obj.name,
            video_components_id=videos_components_obj.id,
            owner_id=videos_components_obj.owner_id,
        )
        new_video = await video_repository.create(new_video)

        body = {
            'video_components':jsonable_encoder(videos_components_obj),
            'video_id':new_video.id
        }
        
        credentials = pika.PlainCredentials('user', 'user')

        connection = pika.BlockingConnection(
                pika.ConnectionParameters(
                host='localhost', 
                port=5672,
                virtual_host='/',
                credentials=credentials
            )
        )

        channel = connection.channel()
        channel.queue_declare(queue='task_queue', durable=True)

        channel.basic_publish(
            exchange='',
            routing_key='task_queue',
            body = json.dumps(body),
            properties=pika.BasicProperties(
                delivery_mode=2,  # make message persistent
            ),
        )
        connection.close()

сделать выходную очередь, где смотреть результат

ассоциации по messageId там или любому другому correlationId

Здраствуйте  кого интересует работа на удаленке надо зделать BATnik которий будет запросавми долбить приложение ,

Ребят привет, вопрос: на каком языке лучше написать многопоточный парсер?

на любимом:)

На том, кто умеет в потоки

Erlang нахваливают...

Haskell

@WanderPrince @Cocloboc благодарю🙏

есть клиентская база твоей матери?

Добрый день. Помогите, пожалуйста. Как указать путь к файлу, который находится на рабочем столе, если программа находится в папке?

есть абсолютный и относительный путь

А как мне, например, в том же python указать абсолютный путь к файлу?

начиная от корня. в линуксе это / на винде диск. например 'C:\'

Спасибо

Здравствуйте. Кому-нибудь интересна работа программистом 1С частично в офисе?

Всем привет, может кто помочь решить 2 задачи по паскалю ?)))) $ отблагодарю немного.

Пиши свои задачи)