From 860e58d32ba8fd722805a538a38ae1bcf328e753 Mon Sep 17 00:00:00 2001 From: dakota002 Date: Tue, 26 Nov 2024 14:59:30 -0500 Subject: [PATCH] Just delete, no comments --- gcn_monitor/kafka.py | 26 -------------------------- 1 file changed, 26 deletions(-) diff --git a/gcn_monitor/kafka.py b/gcn_monitor/kafka.py index b324964..8d99849 100644 --- a/gcn_monitor/kafka.py +++ b/gcn_monitor/kafka.py @@ -78,32 +78,6 @@ def run(): while True: for message in consumer.consume(timeout=1): topic = message.topic() - # file_name, message_key_file_name, headers_file_name = parse_filenames( - # message - # ) - # s3_client.put_object( - # Bucket=bucketName, - # Key=file_name, - # Body=message.value(), - # ) - - # if message_key_file_name is not None: - # s3_client.put_object( - # Bucket=bucketName, - # Key=message_key_file_name, - # Body=message.key(), - # ) - - # if headers_file_name is not None: - # s3_client.put_object( - # Bucket=bucketName, - # Key=headers_file_name, - # Body={ - # key: b64encode(value).decode() - # for key, value in message.headers() - # }, - # ) - if error := message.error(): log.error("topic %s: got error %s", topic, error) else: