Azure Synapse与营销自动化平台集成：数据提取方法咨询

以下是几种适配不同场景的直接可行提取方法：

1. 通过Synapse SQL池直接查询导出 #

• 在Synapse Studio、Azure Data Studio或SSMS中连接你的Synapse SQL池，执行筛选购买者列表的SQL查询（例如SELECT email, customer_id, segment FROM sales.customers WHERE purchase_date >= '2024-01-01'）。
• 导出方式：
  • 使用Synapse Studio的导出功能，将结果保存到ADLS Gen2或Blob Storage的CSV/Parquet文件中。
  • 用COPY INTO命令直接将查询结果导出到存储：

    COPY INTO 'abfss://your-container@your-storage.dfs.core.windows.net/buyers_list.csv'
    FROM (SELECT email, full_name FROM your_target_table WHERE eligibility = 1)
    WITH (
        FILE_TYPE = 'CSV',
        FIELD_TERMINATOR = ',',
        ROWTERMINATOR = '0x0A'
    )
    

2. 利用Synapse Pipeline数据流提取 #

• 构建Synapse数据流，将Synapse SQL池或Lake Database设为数据源，配置筛选条件获取目标购买者数据。
• 可选择将数据输出到ADLS/Blob存储作为中间层，或者直接通过HTTP连接器将数据传递给营销自动化API（适合批量推送场景）。
• 优势：支持定时调度，自动重复执行数据提取任务。

3. Serverless SQL查询提取（针对湖仓数据） #

• 如果整合数据存储在Data Lake中，用Serverless SQL查询外部表或直接读取文件：

  SELECT email, phone 
  FROM OPENROWSET(
      BULK 'abfss://container@storage.dfs.core.windows.net/raw_data/*.parquet',
      FORMAT = 'PARQUET'
  ) AS lake_data
  WHERE purchase_flag = 1
  

• 用bcp工具将查询结果导出到本地或存储文件：

  bcp "SELECT email, phone FROM OPENROWSET(BULK 'abfss://container@storage.dfs.core.windows.net/raw_data/*.parquet', FORMAT='PARQUET') AS t" queryout "buyers.csv" -S your-synapse-ondemand.sql.azuresynapse.net -d master -U your-username -P your-password -c -t,
  

4. 自定义脚本/函数直接提取并推送 #

• 用Python/C#编写脚本或Azure Function，通过ODBC/JDBC连接Synapse SQL池，执行查询获取数据后直接调用营销自动化API：
  Python示例（基于pyodbc）：

  import pyodbc
  import requests
  
  # 连接Synapse SQL池
  conn = pyodbc.connect('DRIVER={ODBC Driver 18 for SQL Server};SERVER=your-synapse.sql.azuresynapse.net;DATABASE=your-db;UID=your-user;PWD=your-pass;Encrypt=yes')
  cursor = conn.cursor()
  
  # 查询购买者数据
  cursor.execute("SELECT email, full_name FROM your_table WHERE eligible = 1")
  buyers = cursor.fetchall()
  
  # 调用营销API推送（示例）
  for buyer in buyers:
      payload = {"email": buyer[0], "name": buyer[1]}
      requests.post("https://your-marketing-api.com/lists/add", json=payload)
  
  conn.close()
  

内容的提问来源于stack exchange，提问作者Mo Hassan