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

v3 25

Browse Source
This commit is contained in:
bskjon 2024-07-18 21:12:19 +02:00
parent fc4ec73894
commit a5fc251da7
2 changed files with 14 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/tasksV2/listeners/CoverFromMetadataTaskListener.kt
View File

@ -53,7 +53,7 @@ class CoverFromMetadataTaskListener: CoordinatorEventListener() {
val metadata = events.findLast { it.eventType == Events.EventMediaMetadataSearchPerformed }?.az<MediaMetadataReceivedEvent>()?.data val metadata = events.findLast { it.eventType == Events.EventMediaMetadataSearchPerformed }?.az<MediaMetadataReceivedEvent>()?.data
if (metadata == null) { if (metadata == null) {
log.info { "No metadata.." } //log.info { "No metadata.." }
return return
} }
val mediaOutInfo = events.find { it.eventType == Events.EventMediaReadOutNameAndType }?.az<MediaOutInformationConstructedEvent>()?.data val mediaOutInfo = events.find { it.eventType == Events.EventMediaReadOutNameAndType }?.az<MediaOutInformationConstructedEvent>()?.data

21
apps/pyMetadata/app.py
View File

@ -52,11 +52,11 @@ class EventsPullerThread(threading.Thread):
self.shutdown = threading.Event() self.shutdown = threading.Event()
def run(self) -> None: def run(self) -> None:
logger.info(f"Using {events_server_address}:{events_server_port} on table: {events_server_database_name}")
while not self.shutdown.is_set(): while not self.shutdown.is_set():
connection = None connection = None
cursor = None cursor = None
try: try:
logger.info(f"Connecting to {events_server_address}:{events_server_port} on table: {events_server_database_name}")
connection = mysql.connector.connect( connection = mysql.connector.connect(
host=events_server_address, host=events_server_address,
port=events_server_port, port=events_server_port,
@ -66,13 +66,18 @@ class EventsPullerThread(threading.Thread):
) )
cursor = connection.cursor(dictionary=True) cursor = connection.cursor(dictionary=True)
cursor.execute(""" cursor.execute("""
SELECT e1.* SELECT *
FROM events e1 FROM events
LEFT JOIN events e2 WHERE referenceId IN (
ON e1.referenceId = e2.referenceId SELECT referenceId
AND e2.event = 'event:media-metadata-search:performed' FROM events
WHERE e1.event = 'event:media-read-base-info:performed' GROUP BY referenceId
AND e2.referenceId IS NULL; HAVING
SUM(event = 'event:media-read-base-info:performed') > 0
AND SUM(event = 'event:media-metadata-search:performed') = 0
AND SUM(event = 'event:media-process:completed') = 0
)
AND event = 'event:media-read-base-info:performed';
""") """)
# not event:media-metadata-search:performed # not event:media-metadata-search:performed
for row in cursor.fetchall(): for row in cursor.fetchall():