ConfigMap

This commit is contained in:
Gui Heise 2022-02-04 16:21:58 -05:00 committed by Luke Van Seters
parent b1d4cb852b
commit 00dba743d9
3 changed files with 12 additions and 7 deletions

View File

@ -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"] resource_deps=["postgresql"]
) )
k8s_yaml(configmap_from_dict("mev-inspect-export", inputs = {
"export-bucket-name" : "local-export",
}))

View File

@ -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 }}

View File

@ -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(