@@ -91,7 +91,7 @@ for (( batch_start_block=$start_block; batch_start_block <= $end_block; batch_st
91
91
transactions_file=${transactions_output_dir} /transactions_${file_name_suffix} .csv
92
92
log " Exporting blocks ${block_range} to ${blocks_file} "
93
93
log " Exporting transactions from blocks ${block_range} to ${transactions_file} "
94
- python3 export_blocks_and_transactions.py --start-block=${batch_start_block} --end-block=${batch_end_block} --provider-uri=" ${provider_uri} " --blocks-output=${blocks_file} --transactions-output=${transactions_file}
94
+ python3 ethereumetl export_blocks_and_transactions --start-block=${batch_start_block} --end-block=${batch_end_block} --provider-uri=" ${provider_uri} " --blocks-output=${blocks_file} --transactions-output=${transactions_file}
95
95
quit_if_returned_error
96
96
97
97
# ## token_transfers
@@ -101,7 +101,7 @@ for (( batch_start_block=$start_block; batch_start_block <= $end_block; batch_st
101
101
102
102
token_transfers_file=${token_transfers_output_dir} /token_transfers_${file_name_suffix} .csv
103
103
log " Exporting ERC20 transfers from blocks ${block_range} to ${token_transfers_file} "
104
- python3 export_token_transfers.py --start-block=${batch_start_block} --end-block=${batch_end_block} --provider-uri=" ${provider_uri} " --output=${token_transfers_file}
104
+ python3 ethereumetl export_token_transfers --start-block=${batch_start_block} --end-block=${batch_end_block} --provider-uri=" ${provider_uri} " --output=${token_transfers_file}
105
105
quit_if_returned_error
106
106
107
107
# ## receipts_and_logs
@@ -111,7 +111,7 @@ for (( batch_start_block=$start_block; batch_start_block <= $end_block; batch_st
111
111
112
112
transaction_hashes_file=${transaction_hashes_output_dir} /transaction_hashes_${file_name_suffix} .csv
113
113
log " Extracting hash column from transaction file ${transactions_file} "
114
- python3 extract_csv_column.py --input ${transactions_file} --output ${transaction_hashes_file} --column " hash"
114
+ python3 ethereumetl extract_csv_column --input ${transactions_file} --output ${transaction_hashes_file} --column " hash"
115
115
quit_if_returned_error
116
116
117
117
receipts_output_dir=${output_dir} /receipts${partition_dir}
@@ -123,7 +123,7 @@ for (( batch_start_block=$start_block; batch_start_block <= $end_block; batch_st
123
123
receipts_file=${receipts_output_dir} /receipts_${file_name_suffix} .csv
124
124
logs_file=${logs_output_dir} /logs_${file_name_suffix} .csv
125
125
log " Exporting receipts and logs from blocks ${block_range} to ${receipts_file} and ${logs_file} "
126
- python3 export_receipts_and_logs.py --transaction-hashes ${transaction_hashes_file} --provider-uri=" ${provider_uri} " --receipts-output=${receipts_file} --logs-output=${logs_file}
126
+ python3 ethereumetl export_receipts_and_logs --transaction-hashes ${transaction_hashes_file} --provider-uri=" ${provider_uri} " --receipts-output=${receipts_file} --logs-output=${logs_file}
127
127
quit_if_returned_error
128
128
129
129
# ## contracts
@@ -133,15 +133,15 @@ for (( batch_start_block=$start_block; batch_start_block <= $end_block; batch_st
133
133
134
134
contract_addresses_file=${contract_addresses_output_dir} /contract_addresses_${file_name_suffix} .csv
135
135
log " Extracting contract_address from receipt file ${receipts_file} "
136
- python3 extract_csv_column.py --input ${receipts_file} --column contract_address --output ${contract_addresses_file}
136
+ python3 ethereumetl extract_csv_column --input ${receipts_file} --column contract_address --output ${contract_addresses_file}
137
137
quit_if_returned_error
138
138
139
139
contracts_output_dir=${output_dir} /contracts${partition_dir}
140
140
mkdir -p ${contracts_output_dir} ;
141
141
142
142
contracts_file=${contracts_output_dir} /contracts_${file_name_suffix} .csv
143
143
log " Exporting contracts from blocks ${block_range} to ${contracts_file} "
144
- python3 export_contracts.py --contract-addresses ${contract_addresses_file} --provider-uri=" ${provider_uri} " --output=${contracts_file}
144
+ python3 ethereumetl export_contracts --contract-addresses ${contract_addresses_file} --provider-uri=" ${provider_uri} " --output=${contracts_file}
145
145
quit_if_returned_error
146
146
147
147
# ## tokens
@@ -151,15 +151,15 @@ for (( batch_start_block=$start_block; batch_start_block <= $end_block; batch_st
151
151
152
152
token_addresses_file=${token_addresses_output_dir} /token_addresses_${file_name_suffix}
153
153
log " Extracting token_address from token_transfers file ${token_transfers_file} "
154
- python3 extract_csv_column.py -i ${token_transfers_file} -c token_address -o - | sort | uniq > ${token_addresses_file}
154
+ python3 ethereumetl extract_csv_column -i ${token_transfers_file} -c token_address -o - | sort | uniq > ${token_addresses_file}
155
155
quit_if_returned_error
156
156
157
157
tokens_output_dir=${output_dir} /tokens${partition_dir}
158
158
mkdir -p ${tokens_output_dir}
159
159
160
160
tokens_file=${tokens_output_dir} /tokens_${file_name_suffix} .csv
161
161
log " Exporting tokens from blocks ${block_range} to ${tokens_file} "
162
- python3 export_tokens.py --token-addresses ${token_addresses_file} --provider-uri=" ${provider_uri} " --output ${tokens_file}
162
+ python3 ethereumetl export_tokens --token-addresses ${token_addresses_file} --provider-uri=" ${provider_uri} " --output ${tokens_file}
163
163
quit_if_returned_error
164
164
165
165
end_time=$( date +%s)
0 commit comments