Azure Data Factory中如何将Azure SQL表数据生成Excel并存储至Blob/SharePoint？

ADF的复制活动接收器确实没有直接的Excel选项，因为Excel格式的特殊性，没法直接作为复制活动的输出。我们可以走**"先导出CSV，再转Excel"**的两步流程来实现需求，下面分场景细说：

场景1：生成Excel后上传至Blob存储 #

第一步：用复制活动把SQL数据导出成CSV到Blob #

• 新建Azure Blob存储连接器作为接收器，在复制活动的接收器设置里选择DelimitedText（即CSV格式），指定好存储路径和文件名，比如raw-data/output.csv。
• 源端配置Azure SQL Server连接器，选择要导出的目标表，或者编写SQL查询获取需要的数据。

第二步：把CSV转成Excel存到Blob #

有两种常用实现方式：

方法A：使用Azure Function

• 编写C#或Python的Azure Function，触发方式选择Blob触发器，监听第一步中CSV文件的存储路径。
• 函数核心逻辑：读取CSV内容，借助EPPlus（C#）或pandas（Python）将其转换为Excel格式，再将生成的.xlsx文件写入Blob存储的目标路径。
• Python示例代码：

import pandas as pd
from azure.storage.blob import BlobServiceClient
from io import BytesIO
import azure.functions as func

def main(myblob: func.InputStream):
    # 替换为你的Blob存储连接字符串
    blob_service_client = BlobServiceClient.from_connection_string("YOUR_BLOB_CONNECTION_STRING")
    # 读取CSV内容
    df = pd.read_csv(myblob)
    # 将数据写入内存中的Excel缓冲区
    excel_buffer = BytesIO()
    df.to_excel(excel_buffer, index=False)
    excel_buffer.seek(0)
    # 上传生成的Excel文件到Blob
    blob_client = blob_service_client.get_blob_client(container="your-container", blob="final-output/output.xlsx")
    blob_client.upload_blob(excel_buffer, overwrite=True)

方法B：使用Logic Apps

• 创建Logic Apps工作流，触发条件选择当Blob存储中添加或修改文件时，指向第一步的CSV文件路径。
• 添加**"Excel Online (Business)"连接器的"创建表格"**动作，将CSV内容导入生成新的Excel文件。
• 新增**"保存到Blob存储"**动作，将生成的Excel文件保存到Blob的目标路径。

场景2：生成Excel后上传至SharePoint #

第一步：先导出SQL数据到Blob的CSV（同场景1第一步） #

先将SQL数据导出为CSV文件存储到Blob，作为中间过渡文件。

第二步：转成Excel并上传至SharePoint #

方法A：Logic Apps + Excel Online

• 创建Logic Apps工作流，触发条件监听Blob中的CSV文件。
• 使用**"Excel Online (Business)"的"创建表格"**动作生成Excel文件（可临时保存到OneDrive for Business或SharePoint文档库）。
• 添加**"SharePoint"连接器的"上传文件"**动作，将生成的Excel文件上传到目标SharePoint文档库。

方法B：Azure Function直接上传至SharePoint

• 先完成CSV到Excel的转换（逻辑同场景1），然后使用SharePoint REST API或Microsoft Graph API将Excel文件上传到指定文档库。
• C#示例（使用Microsoft Graph API）：

using Microsoft.Graph;
using Azure.Identity;
using System.IO;

// 省略CSV转Excel的逻辑，最终得到excelFileStream流
var graphClient = new GraphServiceClient(new DefaultAzureCredential());
// 替换为你的站点ID、驱动器ID和目标路径
await graphClient.Sites["your-site-id"].Drives["your-drive-id"].Root
    .ItemWithPath("Documents/output.xlsx")
    .Content.Request()
    .PutAsync<DriveItem>(excelFileStream);

额外提示 #

• 如果需要定期执行任务，可以在ADF管道中先运行复制活动导出CSV，再通过**"Web活动"调用Azure Function，或通过"Logic Apps活动"**触发工作流。
• 注意权限配置：确保ADF、Azure Function/Logic Apps拥有Blob存储、SharePoint的读写权限。

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