通过Azure数据工厂创建Blob存储容器 [英] Create blob storage container via Azure data factory

查看:0
本文介绍了通过Azure数据工厂创建Blob存储容器的处理方法,对大家解决问题具有一定的参考价值,需要的朋友们下面随着小编来一起学习吧!

问题描述

我正在处理一个使用Azure数据工厂和Blob存储的项目。我有一个要求,但不确定如何实现它。

要求:

#1检查Blob存储容器是否存在。 #2通过POWER外壳脚本在数据工厂中创建新容器。基本上,只有在管道第一次运行时才会创建容器。 #3调用接口

#1==>;我找到了检查if blob exists,的方法,但找不到容器。

通过Power Shell脚本从Azure数据工厂创建容器的最佳方式是什么:通过批处理?还是通过函数执行更好?

提前感谢您的帮助

推荐答案

正如post所说,我们可以使用GetMetaActivity和If Condition Activity来检查Blob是否存在。如果BLOB不存在,我们可以使用Azure函数创建容器,并通过http GET请求指定容器的名称。我觉得使用Azure函数更方便。

例如,我在Azure函数中使用NodeJS。根据 Azure function javascriptManage blobs with JavaScript v12 SDK in Node.js。我们可以开始一个项目。

将依赖项添加到NodeJS演示。

然后修改一些代码index.js,以便我们可以管理Blob容器(创建容器)。

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


module.exports = async function (context, req) {

    const AZURE_STORAGE_CONNECTION_STRING = "<your_connect_string>";
    const blobServiceClient = BlobServiceClient.fromConnectionString(AZURE_STORAGE_CONNECTION_STRING);

    const name = (req.query.name || (req.body && req.body.name));

    const containerClient = blobServiceClient.getContainerClient(name);

    // Create the container
    const createContainerResponse = await containerClient.create();

    const responseMessage = name
        ? "Container:" + name + " has been created!"
        : "...";

    context.res = {
        // status: 200, /* Defaults to 200 */
        body: responseMessage
    };
}

部署到Azure Function后,我测试了代码,它运行良好。 容器已创建。

这篇关于通过Azure数据工厂创建Blob存储容器的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持IT屋!

查看全文
登录 关闭
扫码关注1秒登录
发送“验证码”获取 | 15天全站免登陆