Skip to content

#409 indexer optimizations #410

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
otselnik merged 10 commits into from
Dec 30, 2021
Merged

#409 indexer optimizations #410

Changes from 1 commit
Commits
Show all changes
10 commits
Select commit Hold shift + click to select a range
47c2c2e
#409 indexer optomizations
otselnik Dec 25, 2021
884b82a
Merge remote-tracking branch 'origin/develop' into 409_indexer_optimi…
otselnik Dec 25, 2021
496e4da
#409 catch exceptiopns
otselnik Dec 25, 2021
4036918
#409 add airdropper and faucet artifacts
otselnik Dec 26, 2021
3e1e825
#409 remove unused variables
otselnik Dec 26, 2021
84d2f8a
#409 return`self.last_slot` to `IndexerBase` class
otselnik Dec 26, 2021
097e839
#409 merge SQLDict and SQLDictBinKey classes to one
otselnik Dec 26, 2021
224f5c2
#409 remove debug log
otselnik Dec 26, 2021
560c4d6
#409 add metrics
otselnik Dec 27, 2021
799285c
421 optimise indexer transaction receipt storage (#423)
ivandzen Dec 30, 2021
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
#409 add metrics
  • Loading branch information
@otselnik
otselnik committed Dec 27, 2021
commit 560c4d6d6fa8e692bab80dcbf7fa5b93e95f70fa
5 changes: 5 additions & 0 deletions proxy/indexer/indexer.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -81,6 +81,8 @@ def process_functions(self):


def process_receipts(self):
start_time = time.time()

counter = 0
holder_table = {}
continue_table = {}
Expand Down Expand Up @@ -442,6 +444,9 @@ def process_receipts(self):
else:
self.processed_slot = max(self.processed_slot, max_slot)

process_receipts_ms = (time.time() - start_time)*1000 # convert this into milliseconds
logger.debug(f"process_receipts_ms: {process_receipts_ms} transaction_receipts.len: {len(self.transaction_receipts)} from {self.processed_slot} to {self.current_slot} slots")



def submit_transaction(self, trx_struct):
Expand Down