如何编写Azure Blob Storage触发器转文件至Data Lake Storage？支持JS/C#吗？有无示例？

Absolutely, your requirement is fully achievable! Let's break this down clearly for you:

1. Is this requirement feasible? #

Yes, totally. You can build an Azure Function with a Blob Storage trigger that automatically moves any uploaded file to Azure Data Lake Storage (ADLS) Gen2 right after it's uploaded. Since ADLS Gen2 is built on top of Azure Blob Storage, we can use Azure's official storage SDKs to interact with both services seamlessly, enabling direct, efficient transfers.

2. Can this be developed in JavaScript, or is C# mandatory? #

You don’t have to use C# at all — JavaScript (Node.js) is fully supported for Azure Functions, and it’s a perfectly valid choice for this scenario. Azure Functions supports multiple languages including JavaScript, TypeScript, C#, Python, and more, so go with whichever you’re most comfortable working with.

3. Example Code (JavaScript) #

Here’s a practical, production-ready example of an Azure Function using a Blob trigger to copy files to ADLS Gen2:

First, install the required npm package in your function project:

npm install @azure/storage-blob

Then, the main function code (index.js):

const { BlobServiceClient } = require("@azure/storage-blob");

// Pull connection strings and container names from environment variables (security best practice)
const sourceBlobConn = process.env.SourceBlobStorageConnectionString;
const adlsConn = process.env.ADLSGen2ConnectionString;
const targetAdlsContainer = process.env.TargetADLSContainerName;

module.exports = async function (context, myBlob) {
    try {
        const sourceBlobName = context.bindingData.name;
        context.log(`Starting processing for blob: ${sourceBlobName}`);

        // Initialize clients for source Blob Storage and target ADLS Gen2
        const sourceClient = BlobServiceClient.fromConnectionString(sourceBlobConn);
        const adlsClient = BlobServiceClient.fromConnectionString(adlsConn);

        // Get references to source blob and target ADLS location
        const sourceContainerClient = sourceClient.getContainerClient(context.bindingData.containerName);
        const sourceBlobClient = sourceContainerClient.getBlobClient(sourceBlobName);
        
        const targetContainerClient = adlsClient.getContainerClient(targetAdlsContainer);
        await targetContainerClient.createIfNotExists(); // Ensure target container exists
        const targetBlobClient = targetContainerClient.getBlobClient(sourceBlobName);

        // Use server-side copy (efficient, no data passes through the function)
        const copyOperation = await targetBlobClient.beginCopyFromURL(sourceBlobClient.url);
        const copyResult = await copyOperation.pollUntilDone();

        if (copyResult.copyStatus === 'success') {
            context.log(`Successfully copied ${sourceBlobName} to ADLS Gen2`);
        } else {
            context.error(`Copy failed for ${sourceBlobName}: ${copyResult.copyStatusDescription}`);
        }
    } catch (error) {
        context.error(`Error processing blob: ${error.message}`);
        throw error;
    }
};

And the function.json binding configuration:

{
  "bindings": [
    {
      "name": "myBlob",
      "type": "blobTrigger",
      "direction": "in",
      "path": "<your-source-blob-container>/{name}",
      "connection": "SourceBlobStorageConnectionString"
    }
  ]
}

Quick Notes: #

• Security First: Never hardcode connection strings — store them in your Azure Function App's Application Settings (they’ll be available as environment variables).
• Server-Side Copy: The example uses beginCopyFromURL which is efficient because the transfer happens directly between Azure services, without routing data through your function. If you need to modify the file during transfer, you can read the myBlob buffer and upload it to ADLS instead.

Bonus: C# Example (if you ever need it) #

If you prefer C# later, here’s a concise snippet:

using Azure.Storage.Blobs;
using Microsoft.Azure.WebJobs;
using Microsoft.Extensions.Logging;

public class BlobToAdlsFunction
{
    [FunctionName("BlobToAdls")]
    public async Task Run(
        [BlobTrigger("<source-container>/{name}", Connection = "SourceBlobStorageConnectionString")] BlobClient sourceBlob,
        string name,
        ILogger log)
    {
        log.LogInformation($"Processing blob: {name}");

        var adlsClient = new BlobServiceClient(Environment.GetEnvironmentVariable("ADLSGen2ConnectionString"));
        var targetContainer = adlsClient.GetBlobContainerClient(Environment.GetEnvironmentVariable("TargetADLSContainerName"));
        await targetContainer.CreateIfNotExistsAsync();
        
        var targetBlob = targetContainer.GetBlobClient(name);
        var copyOperation = await targetBlob.StartCopyFromUriAsync(sourceBlob.Uri);
        await copyOperation.WaitForCompletionAsync();

        log.LogInformation($"Successfully copied {name} to ADLS Gen2");
    }
}

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