Spre deosebire de cozile clasice AMQP (unde mesajul este șters din memorie imediat ce este confirmat de consumator), RabbitMQ Streams stochează mesajele într-un log binar append-only persistent pe disc. Mesajele pot fi recitite de nenumărate ori prin specificarea unui offset sau a unui timestamp, atingând debite de milioane de mesaje pe secundă comparabile cu Apache Kafka.
Declararea unei cozi de tip Stream în Python (Pika)
import pika
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()
# Declararea cozii specificând x-queue-type: stream:
channel.queue_declare(
queue='flux-clickuri-analytics',
durable=True,
arguments={
'x-queue-type': 'stream',
'x-max-length-bytes': 20_000_000_000, # reținere maxim 20 GB de log
'x-max-age': '7D' # expirare după 7 zile
}
)
Întrebări & Exemple de Cod:
RabbitMQ Streams: Procesare de Mare Debit cu Loguri Append-Only și Offset-uriAi o nelămurire despre utilizarea comenzii
RabbitMQ Streams: Procesare de Mare Debit cu Loguri Append-Only și Offset-urisau ai descoperit un truc / fragment de cod util? Distribuie-l cu ceilalți programatori!Fii primul care pune o întrebare sau distribuie un fragment de cod / prompt!
Nu au fost adăugate încă întrebări sau exemple de cod pentru această pagină. Dacă ai întâlnit o problemă sau ai un snippet util, adaugă-l mai jos pentru a-i ajuta pe ceilalți.