Consumer

Blockchain data collection Index / src / data_collection / App / Consumer

Auto-generated documentation for src.data_collection.app.consumer module.

DataConsumer

Show source in init.py:29

Consume transaction hash from a given Kafka topic and save all required data to PostgreSQL.

Signature

class DataConsumer(DataCollector):
    def __init__(self, config: Config, contract_abi: ContractABI) -> None:
        ...

DataConsumer().start_consuming_data

Show source in init.py:105

Start an infinite loop of consuming data from a given topic.

Returns

• exit_code - 0 if no exceptions encountered during data collection, 1 otherwise

Signature

async def start_consuming_data(self) -> int:
    ...

kafka_logs_filter

Show source in init.py:20

Filters out some kafka logs

Signature

def kafka_logs_filter(record) -> bool:
    ...

Modules

• Tx Processor