S3tsvwriter

S3TSVWriter

S3TSVWriter(bucket: Bucket, key: str, *, fields: Sequence[LogFieldRec], fixed: Mapping[str, str] | None = None, safe: bool = True, add_timestamps: bool = True, buftime: float = 0.5, shared_lock: LockType | None = None, buf_poll_rate: float = 0.08)

Manages tail-writes to TSV files stored as S3 Express objects.

stopped property

stopped: bool

Does this object appear to be stopped?

elapsed

elapsed() -> float

How long has it been since we last saw a new entry in the log?

stop

stop() -> None

Shut this object down. Wait up to 10 seconds to finish writes, then stop the write future. There is not a mechanism for restarting: construct a new writer.

write

write(**field_values: str | dict) -> None

Format and submit a write job.