from Modules.Company.CompanyObject import RiskInfo from Modules.ETL.WideETL import DataProcess, DataJob class DragRiskInfoFromTYC(DataProcess): def extract(self): pass def transform(self): pass def load(self): pass class RiskInfoDataJob(RiskInfo): def drag(self): """拉去天眼查数据接口的企业风险信息""" data_job = DataJob( instance=self, title="", job_type="", status="", detail="" ) data_job.processes = [ DragRiskInfoFromTYC ] data_job.start()