add debug log

py_sdk.py

@@ -158,8 +158,9 @@ class PySdk():
         return data
 
     def write_output_to_mysql(self, mysql_url, mysql_prop, table_name, df):
-        # df.show()
+        df.show(10)
         tmp_df = df.filter("1=0")
+        self.logger.log(f"connect mysql: {mysql_url}, {str(mysql_prop)}. \n 创建表: {table_name}")
         tmp_df.write.jdbc(url=mysql_url, table="`" + table_name + "`", mode="overwrite", properties=mysql_prop)
         mysql_ops.alter_table_charset(mysql_url, mysql_prop, table_name)
         df.write.jdbc(url=mysql_url, table="`" + table_name + "`", mode="append", properties=mysql_prop)