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

Changed path

Browse Source
This commit is contained in:
bskjon 2024-06-18 19:23:57 +02:00
parent f8c5c03438
commit 4d4e80a2b9
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

@ -9,17 +9,17 @@ import json
import time import time
from fuzzywuzzy import fuzz from fuzzywuzzy import fuzz
from .algo.AdvancedMatcher import AdvancedMatcher from algo.AdvancedMatcher import AdvancedMatcher
from .algo.SimpleMatcher import SimpleMatcher from algo.SimpleMatcher import SimpleMatcher
from .algo.PrefixMatcher import PrefixMatcher from algo.PrefixMatcher import PrefixMatcher
from clazz.shared import ConsumerRecord, MediaEvent, decode_key, decode_value, suppress_ignore, consume_on_key from clazz.shared import ConsumerRecord, MediaEvent, decode_key, decode_value, suppress_ignore, consume_on_key
from clazz.KafkaMessageSchema import KafkaMessage, MessageDataWrapper from clazz.KafkaMessageSchema import KafkaMessage, MessageDataWrapper
from clazz.Metadata import Metadata from clazz.Metadata import Metadata
from kafka import KafkaConsumer, KafkaProducer from kafka import KafkaConsumer, KafkaProducer
from .sources.anii import Anii from sources.anii import Anii
from .sources.imdb import Imdb from sources.imdb import Imdb
from .sources.mal import Mal from sources.mal import Mal
# Konfigurer Kafka-forbindelsen # Konfigurer Kafka-forbindelsen
bootstrap_servers = os.environ.get("KAFKA_BOOTSTRAP_SERVER") or "127.0.0.1:9092" bootstrap_servers = os.environ.get("KAFKA_BOOTSTRAP_SERVER") or "127.0.0.1:9092"