[Bugfix]修复数据库连接问题

sync/publish/base_publish.py

@@ -88,7 +88,7 @@ class BasePublish(object):
         return result
 
     def check_table_columns(self):
-        source_table_column = self.get_table_columns(self.source_table, config.db_database, self.db)
+        source_table_column = self.get_table_columns(self.source_table, config.rl_db_database, self.db)
         dest_table_column = self.get_table_columns(self.dest_table, config.pub_db_database, self.pub_db)
         if dest_table_column.empty:
             self.create_dest_tables()

sync/publish/default.py

@@ -55,7 +55,7 @@ class DefaultPublish(BasePublish):
 
 if __name__ == '__main__':
     parser = argparse.ArgumentParser()
-    parser.add_argument('--source_table', type=str, default='rl_fof_fund_multi_asset_config')
+    parser.add_argument('--source_table', type=str, default='rl_fof_fund_base_info')
     parser.add_argument('--dest_table', type=str, default=None)
     parser.add_argument('--rebuild', type=bool, default=False)
     parser.add_argument('--update', type=bool, default=False)