内部asin 评分评论数导出到mysql

Pyspark_job/sqoop_export/dwt_self_asin_detail_rating.py

@@ -7,7 +7,8 @@ from utils.secure_db_client import get_remote_engine
 def export_data(site_name, date_type, date_info):
     engine = get_remote_engine(
         site_name="us",  # -> database "selection"
-        db_type="postgresql_cluster",  # -> 服务端 alias "mysql"
+        # db_type="postgresql_cluster",  # 原导出到 pg 集群，改为 MySQL，不再维护
+        db_type="mysql",  # -> 阿里云 MySQL
         # user="fangxingjun",         # -> 服务端 alias "mysql"
         # user_token="5f1b2e9c3a4d7f60"   # 可不传，走默认
     )
@@ -22,7 +23,8 @@ def export_data(site_name, date_type, date_info):
     # sql_drop = f"drop table if exists {import_table};"
     # sql_create = f"create table {import_table} like {target_table};"
     sql_drop = f"drop table if exists {import_table};"  # 删除依赖
-    sql_create = f"""CREATE TABLE {import_table} (LIKE {target_table} INCLUDING ALL);"""  # pg
+    # sql_create = f"""CREATE TABLE {import_table} (LIKE {target_table} INCLUDING ALL);"""  # pg 语法，MySQL 不支持，改为下面的 like 写法
+    sql_create = f"create table {import_table} like {target_table};"  # MySQL：复制目标表结构建临时表
     engine.execute(sql_drop)
     engine.execute(sql_create)
     print(f"sql_drop: {sql_drop}")