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

Updated app.py

Browse Source
This commit is contained in:
Brage 2023-07-21 00:30:56 +02:00
parent 98d5bf8c80
commit ae6f21e8f9
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
pyMetadata/app.py
View File

@ -99,7 +99,7 @@ class KafkaConsumerThread(threading.Thread):
handler_thread = MessageHandlerThread(message) handler_thread = MessageHandlerThread(message)
handler_thread.start() handler_thread.start()
else: else:
logger.info("Ignorert message: key=%s, value=%s", message.key, message.value) logger.info("Ignorert message: key=%s", message.key)
consumer.close() consumer.close()
logger.info("Kafka Consumer stopped") logger.info("Kafka Consumer stopped")
@ -125,16 +125,16 @@ class MessageHandlerThread(threading.Thread):
data_value = self.message.value['data']["title"] data_value = self.message.value['data']["title"]
result = None # Will be assigned by either cache_result or sel.perform_action result = None # Will be assigned by either cache_result or sel.perform_action
print(f"Checking cache for offloading") logger.info("Checking cache for offloading")
cache_result = ResultCache.get(data_value) cache_result = ResultCache.get(data_value)
if cache_result: if cache_result:
print(f"Cache hit for {data_value}") logger.info("Cache hit for %s", data_value)
result = cache_result result = cache_result
else: else:
print(f"Searching in sources for infomration about {data_value}") logger.info("Searching in sources for information about %s", data_value)
result = self.perform_action(title=data_value) result = self.perform_action(title=data_value)
if (result.statusType == "SUCCESS"): if (result.statusType == "SUCCESS"):
print(f"Storing response for {data_value} in-memory cache") logger.info("Storing response for %s in in-memory cache")
ResultCache.add(data_value, result) ResultCache.add(data_value, result)