aYOUne

ay stream

ay stream (Alias: listen)

Live-Stream aller Änderungen einer Collection. Nutzt MongoDB Change-Streams unter der Haube.

Syntax

ay stream <collection> [flags]

Flags

Flag Zweck
--filter '<json>' Nur Änderungen, die einem Filter matchen
--ops insert,update,delete,replace Nur bestimmte Operation-Types
--fields '<json>' Projection auf geänderte Felder
--format json|yaml|table Output-Format

Beispiele

# Alle Consumer-Änderungen
ay stream consumers

# Nur Inserts im CRM-Scope
ay stream consumers --ops insert

# Nur bestimmte Felder bei Updates
ay stream orders \
  --ops update \
  --filter '{"status":"paid"}' \
  --fields '{"_id":1,"total":1,"status":1}'

Output-Pattern

Jede Änderung kommt als JSON-Event:

{
  "op": "update",
  "ns": "consumers",
  "_id": "64a1b2c3...",
  "ts": "2026-04-22T14:32:11.000Z",
  "updatedFields": {"lastLoginAt": "2026-04-22T14:32:10.000Z"},
  "fullDocument": { … }
}

Abbruch

Ctrl-C beendet den Stream sauber.

Leistung

Change-Streams benötigen ein Replica-Set (Standard im aYOUne-Atlas-Cluster). Bei sehr hohem Traffic --filter nutzen, sonst füllt sich das Terminal schnell.

Siehe auch