监听以太坊数据

轮询并将结果输出到 Kafka

快速开始

1、修改配置文件

重命名配置文件：

mv config.ini.example config.ini

并修改配置文件 config.ini 中的连接参数。

2、创建 Kafka 主题

在配置文件 config.ini 中可以看到 6 个 Kafka Topic，请创建。

export zookeeper_url=172.31.45.92:2181
kafka-topic.sh --create --zookeeper $zookeeper_url --topic bsc_block --partitions 1 --replication-factor 1
kafka-topic.sh --create --zookeeper $zookeeper_url --topic bsc_transaction --partitions 1 --replication-factor 1
kafka-topic.sh --create --zookeeper $zookeeper_url --topic bsc_log --partitions 1 --replication-factor 1
kafka-topic.sh --create --zookeeper $zookeeper_url --topic bsc_receipt --partitions 1 --replication-factor 1
kafka-topic.sh --create --zookeeper $zookeeper_url --topic bsc_token --partitions 1 --replication-factor 1
kafka-topic.sh --create --zookeeper $zookeeper_url --topic bsc_contract --partitions 1 --replication-factor 1

3、准备 Python3 环境

安装 Python3，然后运行下面的命令安装相关依赖。

pip3 install -r requirements.txt

4、运行

下面 4 个脚本分别处理不同的数据。

python monitor_block_and_transaction.py
python monitor_log.py
python monitor_receipt_and_contract.py
python monitor_token.py