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

Error handling

Browse Source
This commit is contained in:
bskjon 2024-11-07 00:43:23 +01:00
parent 3712ebb115
commit 717350e23c
1 changed files with 19 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

32
apps/pyMetadata/app.py
View File

@ -166,6 +166,7 @@ class EventsPullerThread(threading.Thread):
else: else:
logging.debug("A successful connection has been made!") logging.debug("A successful connection has been made!")
event: MediaEvent | None = None
try: try:
rows = self.getEventsAvailable(connection=self.connection) rows = self.getEventsAvailable(connection=self.connection)
if (len(rows) == 0): if (len(rows) == 0):
@ -183,7 +184,7 @@ Found message
============================================================================\n""" ============================================================================\n"""
logger.info(logMessage) logger.info(logMessage)
event: MediaEvent = json_to_media_event(row["data"]) event = json_to_media_event(row["data"])
producedEvent = asyncio.run(MetadataEventHandler(event).run()) producedEvent = asyncio.run(MetadataEventHandler(event).run())
producedMessage = f""" producedMessage = f"""
@ -201,19 +202,22 @@ Producing message
except Exception as e: except Exception as e:
"""Produce failure here""" """Produce failure here"""
logger.exception(e) logger.exception(e)
producedEvent = MediaEvent( try:
metadata = EventMetadata( producedEvent = MediaEvent(
referenceId=event.metadata.referenceId, metadata = EventMetadata(
eventId=str(uuid.uuid4()), referenceId=event.metadata.referenceId,
derivedFromEventId=event.metadata.eventId, eventId=str(uuid.uuid4()),
status= "Failed", derivedFromEventId=event.metadata.eventId,
created= datetime.now().isoformat(), status= "Failed",
source="metadataApp" created= datetime.now().isoformat(),
), source="metadataApp"
data=None, ),
eventType="EventMediaMetadataSearchPerformed" data=None,
) eventType="EventMediaMetadataSearchPerformed"
self.storeProducedEvent(connection=self.connection, event=producedEvent) )
self.storeProducedEvent(connection=self.connection, event=producedEvent)
except Exception as iex:
logger.error("Failed to push error to database..")
except mysql.connector.Error as err: except mysql.connector.Error as err:
logger.error("Database error: %s", err) logger.error("Database error: %s", err)