trinity.buffer.storage.file module

File Storage

class trinity.buffer.storage.file.FileStorage(config: StorageConfig)

基类：object

A wrapper of a local jsonl file.

If wrap_in_ray in StorageConfig is True, this class will be run as a Ray Actor, and provide a remote interface to the local file.

This wrapper is only for writing, if you want to read from the file, use StorageType.QUEUE instead.

__init__(config: StorageConfig) → None

classmethod get_wrapper(config: StorageConfig)

write(data: List) → None

read() → List

acquire() → int

release() → int