github/ethereum-etl
1
1
Fork 0
mirror of https://github.com/blockchain-etl/ethereum-etl.git synced 2026-01-09 13:57:54 -05:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #271 from numonedad/bugfix/poachain

Browse Source 
adds support for non-mainnet in etl stream
This commit is contained in:
Evgeny Medvedev
2022-01-07 02:15:06 +07:00
committed by GitHub
parent 7d47dd34d6 42b96bcf7b
commit 167b38b6bc
2 changed files with 7 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
.gitignore vendored
View File

@@ -47,3 +47,6 @@ coverage.xml
.venv
venv/
ENV/
# etl
/last_synced_block.txt

5
ethereumetl/streaming/eth_streamer_adapter.py
View File

@@ -15,6 +15,7 @@ from ethereumetl.streaming.eth_item_id_calculator import EthItemIdCalculator
from ethereumetl.streaming.eth_item_timestamp_calculator import EthItemTimestampCalculator
from ethereumetl.thread_local_proxy import ThreadLocalProxy
from web3 import Web3
from web3.middleware import geth_poa_middleware
class EthStreamerAdapter:
@@ -37,7 +38,9 @@ class EthStreamerAdapter:
self.item_exporter.open()
def get_current_block_number(self):
return int(Web3(self.batch_web3_provider).eth.getBlock("latest").number)
w3 = Web3(self.batch_web3_provider)
w3.middleware_stack.inject(geth_poa_middleware, layer=0)
return int(w3.eth.getBlock("latest").number)
def export_all(self, start_block, end_block):
# Export blocks and transactions