Zum Inhalt springen

Änderungen von Dokument NATS - Technisches Setup

Zuletzt geändert von Daniel Herrmann am 2025/12/14 16:20
Von Version Icon 8.1 Icon
bearbeitet von Daniel Herrmann
am 2025/09/09 22:59
Änderungskommentar: Es gibt keinen Kommentar für diese Version
Auf Version Icon 7.1 Icon
bearbeitet von Daniel Herrmann
am 2025/09/09 21:08
Änderungskommentar: Es gibt keinen Kommentar für diese Version

Zusammenfassung

Details

Icon Seiteneigenschaften
Inhalt
... ... @@ -233,16 +233,6 @@
233 233  (% class="nc" %){{code language="none"}}UserEvent{{/code}}
234 234  )))
235 235  
236 -Die Consumer können dann wie folgt angelegt werden:
237 -
238 -{{code language="json"}}
239 -$ nats consumer add backend_events <name> --pull --filter="<filter>" --defaults
240 -
241 -# Beispiel
242 -nats consumer add backend_events backend_briefing_offer_cancelled --pull --filter="mksp.backend.briefing.offer.cancelled" --defaults
243 -nats consumer add backend_events backend_key_assigned --pull --filter="mksp.backend.key.assigned" --defaults
244 -{{/code}}
245 -
246 246  = {{id name="NATSSetup-Troubleshooting"/}}Troubleshooting =
247 247  
248 248  Man kann über die NATS CLI mit dem Server interagieren.
... ... @@ -249,8 +249,6 @@
249 249  
250 250  == {{id name="NATSSetup-JetStream"/}}JetStream ==
251 251  
252 -=== {{id name="NATSSetup-Streams"/}}Streams ===
253 -
254 254  Man kann sich die vorhandenen Streams und die Anzahl der Nachrichten anschauen. Die Anzahl sollte üblicherweise 0 sein, wenn die Zahl höher ist, werden Events nicht richtig abgearbeitet.
255 255  
256 256  {{code language="shell"}}
... ... @@ -275,58 +275,6 @@
275 275  {"timestamp":"2025-09-08T09:06:00.062358","stora
276 276  {{/code}}
277 277  
278 -=== {{id name="NATSSetup-Consumer"/}}Consumer ===
279 -
280 -Die bestehenden Consumer kann man sich ebenfalls im Jetstream Context anzeigen lassen:
281 -
282 -{{code language="json"}}
283 -$ nats consumer ls backend_events
284 -╭──────────────────────────────────────────────────────────────────────────────────────────────────────────────────╮
285 -│ Consumers │
286 -├──────────────────────────────────┬─────────────┬─────────────────────┬─────────────┬─────────────┬───────────────┤
287 -│ Name │ Description │ Created │ Ack Pending │ Unprocessed │ Last Delivery │
288 -├──────────────────────────────────┼─────────────┼─────────────────────┼─────────────┼─────────────┼───────────────┤
289 -│ backend_briefing_offer_cancelled │ │ 2025-09-09 22:53:26 │ 0 │ 0 │ never │
290 -│ backend_key_assigned │ │ 2025-09-09 22:54:01 │ 0 │ 0 │ never │
291 -╰──────────────────────────────────┴─────────────┴─────────────────────┴─────────────┴─────────────┴───────────────╯
292 -{{/code}}
293 -
294 -In dieser Tabelle sieht man bereits die "unprocessed" Nachrichten, sieht also gut, wenn n8n die Nachrichten nicht korrekt verarbeitet. Man kann sich ebenfalls die Details eines Consumers anzeigen lassen:
295 -
296 -{{code language="json"}}
297 -$ nats consumer info backend_events backend_briefing_offer_cancelled
298 -
299 -Information for Consumer backend_events > backend_briefing_offer_cancelled created 2025-09-09 22:53:26
300 -
301 -Configuration:
302 -
303 - Name: backend_briefing_offer_cancelled
304 - Pull Mode: true
305 - Filter Subject: mksp.backend.briefing.offer.cancelled
306 - Deliver Policy: All
307 - Ack Policy: Explicit
308 - Ack Wait: 30.00s
309 - Replay Policy: Instant
310 - Max Ack Pending: 1,000
311 - Max Waiting Pulls: 512
312 -
313 -State:
314 -
315 - Host Version: 2.11.8
316 - Required API Level: 0 hosted at level 1
317 - Last Delivered Message: Consumer sequence: 0 Stream sequence: 10
318 - Acknowledgment Floor: Consumer sequence: 0 Stream sequence: 0
319 - Outstanding Acks: 0 out of maximum 1,000
320 - Redelivered Messages: 0
321 - Unprocessed Messages: 0
322 - Waiting Pulls: 1 of maximum 512
323 -{{/code}}
324 -
325 -Insbesondere die letzten beiden Zeilen sind wichtig:
326 -
327 -* **Unprocessed Messages** sind Nachrichten, die noch nicht abgerufen wurden. Dies sollte immer 0 sein
328 -* **Waiting Pulls**: die Anzahl der verbundenen Clients. Üblicherweise sollte das nur n8n sein, also immer 1.
329 -
330 330  == {{id name="NATSSetup-Server"/}}Server ==
331 331  
332 332  Man kann sich ebenfalls die aktiven Verbindungen anzeigen:
Icon Confluence.Code.ConfluencePageClass[0]
Id
... ... @@ -1,1 +1,1 @@
1 -207814677
1 +207814676
URL
... ... @@ -1,1 +1,1 @@
1 -https://wiki.makerspace-darmstadt.de/spaces/PROJ/pages/207814677/NATS Setup
1 +https://wiki.makerspace-darmstadt.de/spaces/PROJ/pages/207814676/NATS Setup