Commit 746d763a authored by Nane Kratzke's avatar Nane Kratzke
Browse files

Reduced production rate for queueing producer

parent 9c64ec19
......@@ -122,7 +122,8 @@ Diese Übung zeigt Ihnen wie man Redis als persistentes Messaging System einsetz
- Lesen Sie sich hierzu als erstes ein wenig in [Redis Streams](https://redis.io/topics/streams-intro) ein.
- Studieren Sie anschließend die Klasse `messaging/MQueue.py`. Hier ist Ihnen eine Wrapper-Klasse um Redis gegeben, die die Commands `xadd`, `xread` und `xgroupread` so kapselt, dass diese komfortabel mittels einer `listen()`-Methode für Consumer und mittels einer `publish()`-Methode für Producer genutzt werden kann. *Auf `listen_as_group()` gehen wir in Übung 04 noch genauer ein.*
- Starten Sie nun in Gitlab manuell die Jobs `queueing-consumer` und `queueing-producer` in der `deploy`-Stage.
- Versuchen Sie nun die Dateien `messaging/queueing-producer.py` und `messaging/queueing-consumer.py` nachzuvollziehen, um zu verstehen, wie man die Klasse `MQueue` für ein Publish-Subscribe Pattern einsetzen kann.
- Starten Sie nun in Gitlab manuell die Jobs `queueing-consumer` und `queueing-producer` in der `deploy`-Stage um einen Consumer und einen Producer zu erzeugen.
## Übung 03: Event Sourcing
......
......@@ -13,8 +13,8 @@ i = 0
while True:
i = i + 1
msg = f"Hi, this is message #{ i } from { queue.host }."
n = random.randint(1, 10)
time.sleep(n / 10)
n = random.randint(1, 5)
time.sleep(n)
try:
queue.publish({ 'text': msg })
except Exception as ex:
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment