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

Update

Browse Source
This commit is contained in:
bskjon 2024-06-18 19:12:38 +02:00
parent 8746ed0d6f
commit 4f0886b3fd
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
apps/pyMetadata/app.py
View File

@ -7,14 +7,14 @@ import uuid
import threading
import json
import time
from .clazz.shared import ConsumerRecord, MediaEvent, decode_key, decode_value, suppress_ignore, consume_on_key
from fuzzywuzzy import fuzz
from .algo.AdvancedMatcher import AdvancedMatcher
from .algo.SimpleMatcher import SimpleMatcher
from .algo.PrefixMatcher import PrefixMatcher
from .clazz.KafkaMessageSchema import KafkaMessage, MessageDataWrapper
from .clazz.Metadata import Metadata
from algo.AdvancedMatcher import AdvancedMatcher
from algo.SimpleMatcher import SimpleMatcher
from algo.PrefixMatcher import PrefixMatcher
from clazz.shared import ConsumerRecord, MediaEvent, decode_key, decode_value, suppress_ignore, consume_on_key
from clazz.KafkaMessageSchema import KafkaMessage, MessageDataWrapper
from clazz.Metadata import Metadata
from kafka import KafkaConsumer, KafkaProducer
from .sources.anii import Anii