from loader.DDBHFTLoader import DDBHFTLoader from loader.DDBBasicInfoLoader import DDBBasicInfoLoader def main(): # TODO: # 可以使用`Fire`库,对函数调用再做一次封装,就可以避免每次运行不同参数时候需要修改内部多处的代码。 #loader = DDBBasicInfoLoader() #loader.create_ddb_database() #loader.create_ddb_partition_table() # 高频数据 loader = DDBHFTLoader() df_calendar = loader.make_calendar_df() #loader.init_ddb_database(df_calendar) #print('Did finish init_ddb_database') loader.load_ddb_database() print('Did load ddb database') loader.init_ddb_table_data(df_calendar) print('Did finish init_table_data') if __name__ == '__main__': main()