long_articles_agentic_supply/supply/infra/__init__.py

"""基础设施层 —— 数据库后端、HTTP 客户端、日志服务、工具函数等底层能力"""

from supply.infra.database import (
    BaseBackend,
    SqlBackend,
    VectorBackend,
    KvBackend,
    BackendType,
    MySQLBackend,
    PgBackend,
    MilvusBackend,
    RedisBackend,
    DatabaseManager,
    create_backend,
)
from supply.infra.observability import (
    LogCategory,
    LogLevel,
    LogStatus,
    LogRecord,
    LogService,
    SLS_INDEX_CONFIG,
)
from supply.infra.shared import (
    AsyncHttpClient,
    run_tasks_with_async_worker_group,
    run_tasks_with_asyncio_task_group,
    safe_json_parse,
    str_to_md5,
    generate_task_trace_id,
    yield_batch,
    timestamp_to_str,
    days_remaining_in_month,
)
from supply.infra.xxl_jobs import (
    XxlJobConfig,
    xxl_job,
    xxl_registry,
    XxlJobExecutor,
)

__all__ = [
    # 数据库
    "BaseBackend",
    "SqlBackend",
    "VectorBackend",
    "KvBackend",
    "BackendType",
    "MySQLBackend",
    "PgBackend",
    "MilvusBackend",
    "RedisBackend",
    "DatabaseManager",
    "create_backend",
    # 可观测性
    "LogCategory",
    "LogLevel",
    "LogStatus",
    "LogRecord",
    "LogService",
    "SLS_INDEX_CONFIG",
    # 共享工具
    "AsyncHttpClient",
    "run_tasks_with_async_worker_group",
    "run_tasks_with_asyncio_task_group",
    "safe_json_parse",
    "str_to_md5",
    "generate_task_trace_id",
    "yield_batch",
    "timestamp_to_str",
    "days_remaining_in_month",
    # 任务调度
    "XxlJobConfig",
    "xxl_job",
    "xxl_registry",
    "XxlJobExecutor",
]