LongArticlesJob/fwh_data_manager.py

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


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

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