LongArticlesJob/fwh_data_manager.py

from tasks.data_tasks.fwh_data_recycle import FwhGroupPublishRecordManager
from tasks.data_tasks.fwh_data_recycle import SaveFwhDataToDatabase
from tasks.data_tasks.fwh_data_recycle import FwhGroupPublishMonitor


if __name__ == '__main__':
    # 1. 从 aigc 获取数据
    fwh_group_publish_record_manager = FwhGroupPublishRecordManager()
    fwh_group_publish_record_manager.deal()

    # 2. 保存数据到数据库
    save_fwh_data_to_database = SaveFwhDataToDatabase()
    save_fwh_data_to_database.deal()

    # 3. 监测报警
    fwh_group_publish_monitor = FwhGroupPublishMonitor()
    fwh_group_publish_monitor.deal()