使用python (web3py)订阅新的块头

Question

我在web3py中寻找一个订阅函数，就像在web3js中实现的那样：

web3.eth.subscribe('newBlockHeaders' [, callback]);

由于在web3py中目前还没有它的实现，是否有人对可能的实现有一个想法，或者在它上有一些资源？

Answer 1

最简单的解决方案是使用过滤器。您可以找到几个在web3.py文档中筛选使用示例。下面是同步示例：

from web3.auto import w3
import time

def handle_event(event):
    print(event)

def log_loop(event_filter, poll_interval):
    while True:
        for event in event_filter.get_new_entries():
            handle_event(event)
        time.sleep(poll_interval)

def main():
    block_filter = w3.eth.filter('latest')
    log_loop(block_filter, 2)

if __name__ == '__main__':
    main()

过滤“最新”将返回最近的块哈希，一旦他们成为可用。

上面的链接中也有异步示例。