Class MutationsBatcher (2.28.1)

Version latest

• 2.28.1 (latest)
• 2.28.0
• 2.26.0
• 2.25.0
• 2.24.0
• 2.23.1
• 2.22.0
• 2.21.0
• 2.20.0
• 2.19.0
• 2.18.1
• 2.17.0
• 2.16.0
• 2.15.0
• 2.14.1
• 2.13.2
• 2.12.0
• 2.11.3
• 2.10.1
• 2.9.0
• 2.8.1
• 2.7.1
• 2.6.0
• 2.5.2
• 2.4.0
• 2.3.3
• 2.2.0
• 2.1.0
• 2.0.0
• 1.7.3
• 1.6.1
• 1.5.1
• 1.4.0
• 1.3.0
• 1.2.1
• 1.1.0
• 1.0.0
• 0.34.0

MutationsBatcher(
    table: TableType,
    *,
    flush_interval: float | None = 5,
    flush_limit_mutation_count: int | None = 1000,
    flush_limit_bytes: int = 20971520,
    flow_control_max_mutation_count: int = 100000,
    flow_control_max_bytes: int = 104857600,
    batch_operation_timeout: float | TABLE_DEFAULT = TABLE_DEFAULT.MUTATE_ROWS,
    batch_attempt_timeout: float | None | TABLE_DEFAULT = TABLE_DEFAULT.MUTATE_ROWS,
    batch_retryable_errors: (
        Sequence[type[Exception]] | TABLE_DEFAULT
    ) = TABLE_DEFAULT.MUTATE_ROWS
)

Allows users to send batches using context manager API:

Runs mutate_row, mutate_rows, and check_and_mutate_row internally, combining to use as few network requests as required

Will automatically flush the batcher:

• every flush_interval seconds
• after queue size reaches flush_limit_mutation_count
• after queue reaches flush_limit_bytes
• when batcher is closed or destroyed

Properties

closed

Returns:

• True if the batcher is closed, False otherwise

Methods

__enter__

__enter__()

Allow use of context manager API

__exit__

__exit__(exc_type, exc, tb)

Allow use of context manager API.

Flushes the batcher and cleans up resources.

append

append(mutation_entry: RowMutationEntry)

Add a new set of mutations to the internal queue

Exceptions
Type	Description
RuntimeError	if batcher is closed
ValueError	if an invalid mutation type is added

close

close()

Flush queue and clean up resources