crowetic/mev-inspect-py
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Add a shell of a command to do the export

Browse Source
This commit is contained in:
Luke Van Seters 2022-02-04 13:09:46 -05:00
parent 17dec2b203
commit e0fc9e7776
3 changed files with 24 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
cli.py
View File

@ -120,6 +120,14 @@ def fetch_all_prices():
write_prices(inspect_db_session, prices) write_prices(inspect_db_session, prices)
@cli.command()
@click.argument("after_block_number", type=int)
@click.argument("before_block_number", type=int)
def s3_export(after_block_number: int, before_block_number: int):
logger.info(after_block_number)
logger.info(before_block_number)
@cli.command() @cli.command()
@click.argument("after", type=click.DateTime(formats=["%Y-%m-%d", "%m-%d-%Y"])) @click.argument("after", type=click.DateTime(formats=["%Y-%m-%d", "%m-%d-%Y"]))
@click.argument("before", type=click.DateTime(formats=["%Y-%m-%d", "%m-%d-%Y"])) @click.argument("before", type=click.DateTime(formats=["%Y-%m-%d", "%m-%d-%Y"]))

23
mev
View File

@ -46,11 +46,11 @@ case "$1" in
kubectl exec -ti deploy/mev-inspect -- ./listener $2 kubectl exec -ti deploy/mev-inspect -- ./listener $2
;; ;;
backfill) backfill)
start_block_number=$2 after_block_number=$2
end_block_number=$3 before_block_number=$3
echo "Backfilling from $start_block_number to $end_block_number" echo "Backfilling from $after_block_number to $before_block_number"
kubectl exec -ti deploy/mev-inspect -- poetry run enqueue-many-blocks $start_block_number $end_block_number kubectl exec -ti deploy/mev-inspect -- poetry run enqueue-many-blocks $after_block_number $before_block_number
;; ;;
inspect) inspect)
block_number=$2 block_number=$2
@ -58,11 +58,11 @@ case "$1" in
kubectl exec -ti deploy/mev-inspect -- poetry run inspect-block $block_number kubectl exec -ti deploy/mev-inspect -- poetry run inspect-block $block_number
;; ;;
inspect-many) inspect-many)
start_block_number=$2 after_block_number=$2
end_block_number=$3 before_block_number=$3
echo "Inspecting from block $start_block_number to $end_block_number" echo "Inspecting from block $after_block_number to $before_block_number"
kubectl exec -ti deploy/mev-inspect -- \ kubectl exec -ti deploy/mev-inspect -- \
poetry run inspect-many-blocks $start_block_number $end_block_number poetry run inspect-many-blocks $after_block_number $before_block_number
;; ;;
test) test)
shift shift
@ -94,6 +94,13 @@ case "$1" in
exit 1 exit 1
esac esac
;; ;;
s3-export)
after_block_number=$2
before_block_number=$3
echo "Exporting from $after_block_number to $before_block_number"
kubectl exec -ti deploy/mev-inspect -- poetry run s3-export $after_block_number $before_block_number
;;
exec) exec)
shift shift
kubectl exec -ti deploy/mev-inspect -- $@ kubectl exec -ti deploy/mev-inspect -- $@

1
pyproject.toml
View File

@ -41,6 +41,7 @@ enqueue-many-blocks = 'cli:enqueue_many_blocks_command'
fetch-block = 'cli:fetch_block_command' fetch-block = 'cli:fetch_block_command'
fetch-all-prices = 'cli:fetch_all_prices' fetch-all-prices = 'cli:fetch_all_prices'
fetch-range = 'cli:fetch_range' fetch-range = 'cli:fetch_range'
s3-export = 'cli:s3_export'
[tool.black] [tool.black]
exclude = ''' exclude = '''