Model/backend/condition/processor.py
2026-01-19 16:23:11 +00:00

16 lines
No EOL
571 B
Python

from typing import Any, BinaryIO, List
from backend.condition.parsing.parser import Parser
from utils.logger import setup_logger
from backend.condition.file_type import FileType, detect_file_type
from backend.condition.parsing.factory import select_parser
def process_file(file_stream: BinaryIO, source_key: str) -> None:
print(f"[processor] Received file: {source_key}")
# Instantiation
file_type: FileType = detect_file_type(source_key)
parser: Parser = select_parser(file_type)
# Orchestration
records: List[Any] = parser.parse(file_stream)