Specifies the Streaming Engine message processing guarantees.
Reduces cost and latency but might result in duplicate messages
written to storage. Designed to run simple mapping streaming ETL
jobs at the lowest cost. For example, Change Data Capture (CDC) to
BigQuery is a canonical use case. For more information, see Set the
pipeline streaming
mode <https://cloud.google.com/dataflow/docs/guides/streaming-modes>__.
Enums
Name
Description
STREAMING_MODE_UNSPECIFIED
Run in the default mode.
STREAMING_MODE_EXACTLY_ONCE
In this mode, message deduplication is performed against persistent state to make sure each message is processed and committed to storage exactly once.
STREAMING_MODE_AT_LEAST_ONCE
Message deduplication is not performed. Messages might be processed multiple times, and the results are applied multiple times. Note: Setting this value also enables Streaming Engine and Streaming Engine resource-based billing.
[[["Easy to understand","easyToUnderstand","thumb-up"],["Solved my problem","solvedMyProblem","thumb-up"],["Other","otherUp","thumb-up"]],[["Hard to understand","hardToUnderstand","thumb-down"],["Incorrect information or sample code","incorrectInformationOrSampleCode","thumb-down"],["Missing the information/samples I need","missingTheInformationSamplesINeed","thumb-down"],["Other","otherDown","thumb-down"]],["Last updated 2025-08-28 UTC."],[],[],null,["# Class StreamingMode (0.9.0)\n\nVersion latestkeyboard_arrow_down\n\n- [0.9.0 (latest)](/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.StreamingMode)\n- [0.8.17](/python/docs/reference/dataflow/0.8.17/google.cloud.dataflow_v1beta3.types.StreamingMode)\n- [0.7.0](/python/docs/reference/dataflow/0.7.0/google.cloud.dataflow_v1beta3.types.StreamingMode)\n- [0.6.2](/python/docs/reference/dataflow/0.6.2/google.cloud.dataflow_v1beta3.types.StreamingMode)\n- [0.5.5](/python/docs/reference/dataflow/0.5.5/google.cloud.dataflow_v1beta3.types.StreamingMode)\n- [0.4.1](/python/docs/reference/dataflow/0.4.1/google.cloud.dataflow_v1beta3.types.StreamingMode)\n- [0.3.1](/python/docs/reference/dataflow/0.3.1/google.cloud.dataflow_v1beta3.types.StreamingMode)\n- [0.2.0](/python/docs/reference/dataflow/0.2.0/google.cloud.dataflow_v1beta3.types.StreamingMode)\n- [0.1.5](/python/docs/reference/dataflow/0.1.5/google.cloud.dataflow_v1beta3.types.StreamingMode) \n\n StreamingMode(value)\n\nSpecifies the Streaming Engine message processing guarantees.\nReduces cost and latency but might result in duplicate messages\nwritten to storage. Designed to run simple mapping streaming ETL\njobs at the lowest cost. For example, Change Data Capture (CDC) to\nBigQuery is a canonical use case. For more information, see `Set the\npipeline streaming\nmode \u003chttps://cloud.google.com/dataflow/docs/guides/streaming-modes\u003e`__."]]
