event_reader.csv_block_data_store

Documentation for eth_defi.event_reader.csv_block_data_store Python module.

CSV file backed block data storage like block headers.

Classes

CSVDatasetBlockDataStore

Store block data as CSV file.

Exceptions

NoGapsWritten

Do not allow gaps in data.
exception NoGapsWritten

Bases: Exception

Do not allow gaps in data.

__init__(*args, **kwargs)
__new__(**kwargs)
add_note()

Exception.add_note(note) – add a note to the exception

with_traceback()

Exception.with_traceback(tb) – set self.__traceback__ to tb and return self.

class CSVDatasetBlockDataStore

Bases: eth_defi.event_reader.block_data_store.BlockDataStore

Store block data as CSV file.

Parameters

path – Path to the CSV file

__init__(path)
Parameters

path (pathlib.Path) – Path to the CSV file

is_virgin()

Has this store any stored data.

Returns

There is data to load.

Return type

bool

load(since_block_number=0)

Load data from CSV file

Parameters

since_block_number (int) – Ignored

Return type

pandas.core.frame.DataFrame

save(df, since_block_number=0, check_contains_all_blocks=True)

Save all data to CSV file.

Parameters

  • since_block_number (int) – Ignored. Does not support incremental writing.

  • check_contains_all_blocks – Check that we have at least one data record for every block. Note that trades might not happen on every block.

  • df (pandas.core.frame.DataFrame) –

save_incremental(df)

Write all partitions we are missing from the data.

Parameters

df (pandas.core.frame.DataFrame) –

Return type

Tuple[int, int]

peak_last_block()

Return the last block number stored on the disk.

Return type

Optional[int]