ConfigMap
This commit is contained in:
parent
1b598394c0
commit
98375e7d39
4
Tiltfile
4
Tiltfile
@ -78,3 +78,7 @@ local_resource(
|
|||||||
serve_cmd='kubectl port-forward --namespace default svc/postgresql 5432:5432',
|
serve_cmd='kubectl port-forward --namespace default svc/postgresql 5432:5432',
|
||||||
resource_deps=["postgresql-postgresql"]
|
resource_deps=["postgresql-postgresql"]
|
||||||
)
|
)
|
||||||
|
|
||||||
|
k8s_yaml(configmap_from_dict("mev-inspect-export", inputs = {
|
||||||
|
"export-bucket-name" : "local-export",
|
||||||
|
}))
|
||||||
|
@ -91,6 +91,11 @@ spec:
|
|||||||
name: mev-inspect-listener-healthcheck
|
name: mev-inspect-listener-healthcheck
|
||||||
key: url
|
key: url
|
||||||
optional: true
|
optional: true
|
||||||
|
- name: EXPORT_BUCKET_NAME
|
||||||
|
valueFrom:
|
||||||
|
configMapKeyRef:
|
||||||
|
name: mev-inspect-export
|
||||||
|
key: export-bucket-name
|
||||||
{{- with .Values.nodeSelector }}
|
{{- with .Values.nodeSelector }}
|
||||||
nodeSelector:
|
nodeSelector:
|
||||||
{{- toYaml . | nindent 8 }}
|
{{- toYaml . | nindent 8 }}
|
||||||
|
@ -1,5 +1,6 @@
|
|||||||
import json
|
import json
|
||||||
import logging
|
import logging
|
||||||
|
import os
|
||||||
|
|
||||||
import boto3
|
import boto3
|
||||||
|
|
||||||
@ -7,7 +8,7 @@ from mev_inspect.text_io import BytesIteratorIO
|
|||||||
|
|
||||||
MEV_SUMMARY_EXPORT_QUERY = """
|
MEV_SUMMARY_EXPORT_QUERY = """
|
||||||
SELECT to_json(mev_summary)
|
SELECT to_json(mev_summary)
|
||||||
FROM mev_summary
|
FROM mev_summary
|
||||||
WHERE
|
WHERE
|
||||||
block_number >= :after_block_number AND
|
block_number >= :after_block_number AND
|
||||||
block_number < :before_block_number
|
block_number < :before_block_number
|
||||||
@ -20,7 +21,7 @@ def export_block_range(
|
|||||||
inspect_db_session, after_block_number: int, before_block_number
|
inspect_db_session, after_block_number: int, before_block_number
|
||||||
) -> None:
|
) -> None:
|
||||||
client = get_s3_client()
|
client = get_s3_client()
|
||||||
bucket_name = get_export_bucket_name()
|
bucket_name = os.environ["EXPORT_BUCKET_NAME"]
|
||||||
|
|
||||||
mev_summary_json_results = inspect_db_session.execute(
|
mev_summary_json_results = inspect_db_session.execute(
|
||||||
statement=MEV_SUMMARY_EXPORT_QUERY,
|
statement=MEV_SUMMARY_EXPORT_QUERY,
|
||||||
@ -45,11 +46,6 @@ def export_block_range(
|
|||||||
logger.info(f"Exported to {key}")
|
logger.info(f"Exported to {key}")
|
||||||
|
|
||||||
|
|
||||||
# TODO - replaced by ConfigMap
|
|
||||||
def get_export_bucket_name() -> str:
|
|
||||||
return "local-export"
|
|
||||||
|
|
||||||
|
|
||||||
# TODO - handle for production
|
# TODO - handle for production
|
||||||
def get_s3_client():
|
def get_s3_client():
|
||||||
return boto3.client(
|
return boto3.client(
|
||||||
|
Loading…
x
Reference in New Issue
Block a user