iktdev/MediaProcessing
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fixing malformed json

Browse Source
This commit is contained in:
bskjon 2024-06-18 19:38:01 +02:00
parent 4d4e80a2b9
commit e3da00ee0d
1 changed files with 2 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
apps/pyMetadata/app.py
View File

@ -138,10 +138,7 @@ class MessageHandlerThread(threading.Thread):
producerMessage = KafkaMessage(referenceId=mediaEvent.referenceId, data=messageData).to_json() producerMessage = KafkaMessage(referenceId=mediaEvent.referenceId, data=messageData).to_json()
# Serialiser resultatet til JSON som strenger logger.info("<== Outgoing message: %s \n%s", self.producerMessageKey, producerMessage)
result_json = json.dumps(producerMessage)
logger.info("<== Outgoing message: %s \n%s", self.producerMessageKey, result_json)
# Send resultatet tilbake ved hjelp av Kafka-producer # Send resultatet tilbake ved hjelp av Kafka-producer
producer = KafkaProducer( producer = KafkaProducer(
@ -149,7 +146,7 @@ class MessageHandlerThread(threading.Thread):
key_serializer=lambda k: k.encode('utf-8') if isinstance(k, str) else None, key_serializer=lambda k: k.encode('utf-8') if isinstance(k, str) else None,
value_serializer=lambda v: v.encode('utf-8') if isinstance(v, str) else None value_serializer=lambda v: v.encode('utf-8') if isinstance(v, str) else None
) )
producer.send(kafka_topic, key=self.producerMessageKey, value=result_json) producer.send(kafka_topic, key=self.producerMessageKey, value=producerMessage)
producer.close() producer.close()