Брокерлік жүйелермен немесе олардың баптауымен жұмыс тәжірибеңіз болды ма?

Иә, менде брокер жүйелерімен жұмыс тәжірибем бар. Бұл әдетте хабарламалар брокерлерін орнату және пайдалану, мысалы, RabbitMQ, Apache Kafka немесе ActiveMQ, тарату компоненттері арасында хабарламалар алмасуды ұйымдастыруды қамтиды.

Орнату кезінде мен кезектерді, тақырыптарды, хабарламаларды жеткізу параметрлерін конфигурацияладым және Python-да кітапханаларды (мысалы, pika RabbitMQ үшін немесе kafka-python Kafka үшін) пайдаланып хабарламаларды жіберу және қабылдау кодын жаздым.

Міне, Python-да pika пайдаланып RabbitMQ-да қарапайым хабарлама жіберушінің мысалы:

import pika

байланыс = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
арна = байланыс.channel()

арна.queue_declare(queue='task_queue', durable=True)

арна.basic_publish(
    exchange='',
    routing_key='task_queue',
    body='Hello World!',
    properties=pika.BasicProperties(
        delivery_mode=2,  # хабарламаны тұрақты ету
    ))

print(" [x] 'Hello World!' хабарламасы жіберілді" )
байланыс.close()