通过Azure数据工厂创建Blob存储容器 [英] Create blob storage container via Azure data factory
本文介绍了通过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 javascript和Manage blobs with JavaScript v12 SDK in Node.js。我们可以开始一个项目。
然后修改一些代码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屋!
查看全文