gws-gmail-watch

To stream new Gmail messages as NDJSON, you run the watch command with your project and topic configurations. This emits incoming emails as structured NDJSON records for seamless ingestion into downstream automation pipelines.

You need the gws CLI and Gmail API access to watch Gmail and route messages to Pub/Sub. Configurable options like --project, --subscription, and --topic let you define the streaming pipeline parameters.

Yes, you can filter Gmail emails during streaming by using the --label-ids option. This ensures only messages matching your specified labels are emitted as NDJSON records to your downstream workflows.

NDJSON streaming for Gmail ingestion works by emitting each new email event as a separate JSON line. This format allows downstream processes to consume and route messages to Pub/Sub or data stores in real time without loading the entire batch.

The best way to archive Gmail messages locally is using the --output-dir option. This writes per-message NDJSON records to a local directory, enabling offline analysis and archival of your email events.

You can control Gmail message streaming volume using the --max-messages and --poll-interval options. These settings configure how frequently the system checks for new emails and how many events to process during each polling cycle.