import pika def process_message(ch, method, properties, body): print(f"Получена вакансия (Consumer 2): {body.decode('utf-8')}") ch.basic_ack(delivery_tag=method.delivery_tag) def consume_messages(channel, queue_name, exchange_name): channel.queue_declare(queue=queue_name) channel.queue_bind(exchange=exchange_name, queue=queue_name) channel.basic_consume(queue=queue_name, on_message_callback=process_message) print("Consumer 2 начал прослушивание сообщений...") channel.start_consuming() def main(): connection = pika.BlockingConnection(pika.ConnectionParameters('localhost')) channel = connection.channel() exchange_name = 'logs' queue_name = 'queue2' consume_messages(channel, queue_name, exchange_name) connection.close() if __name__ == '__main__': main()