azure - 如何使用 Azure Function App 将文件从 Azure Blob 存储容器动态复制到 Cosmos Mongo DB 集合

Question

我们的 azure blob 存储容器中有 11 个 JSON 文件，位于名为 jsonfiles 的文件夹中，假设文件名为 (a.json, b.json, c.json, d.json, e.json, f.json 、g.json、h.json、i.json、j.json、k.json)。

类似地，我们有 11 个 Cosmo Mongo DB Collection，假设集合名称如下 [a, b, c, d, e, f, g, h, I, j, k]。

我需要复制/上传(a.json 文件到“a”集合)、(b.json 到“b”集合)、(c.json 到“c”集合)、(d.json 到“d” '集合)，(e.json到'e'集合)，(f.json到'f'集合)，(g.json到'g'集合)，(h.json到'h'集合)，(i .json 到“i”集合)、(j.json 到“j”集合)、(k.json 到“k”)集合。

我需要通过Azure Function App来实现上述要求。如果有人擅长使用Azure Function，请详细解释如何实现这一点。

非常感谢详细的解释。预先感谢您。

Answer 1

• 要下载 blob，您需要一个 blob 服务客户端、容器客户端和一个 blobclient 。然后我们可以使用downloadtofile函数来下载文件。

• downloadtofile 函数会将文件位置作为输入，并将数据从 blob 写入到同名 blob 的文件中。

• 必须存在同名的 blob 文件。

• 同样，现在您需要一个 MongodbClient 来连接数据库，然后我们可以读取下载的文件并将它们添加到 Json 对象的文档中，然后使用 insertOne 将带有 Json 文件的文档上传到 azure cosmos db mongo db。

• 这里我下载了三个文件并将它们上传到azure

完整代码:

// Dependencies

const { BlobServiceClient } = require("@azure/storage-blob");
const { MongoClient } = require('mongodb');
const  fs = require('fs');
const { ObjectID } = require("bson");

  

const  container_name = "test";
const  connblob = "<Connection String of Storage Account>";

  
  

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

/// Hepls in connecting to Database
const  client = new  MongoClient("< Connectiom String of azure cosmosdb mongodb>");

  
// connecting to blob storage
var  blob_service_client = BlobServiceClient.fromConnectionString(connblob);

// refence of container

var  container_client = blob_service_client.getContainerClient(container_name);

  
  
// Reference of perticular blobs

var  blob_client1 = container_client.getBlobClient("a.json");

// download the blob

await  blob_client1.downloadToFile("./blobs/a.json");

  

var  blob_client2 = container_client.getBlobClient("b.json");

await  blob_client2.downloadToFile("./blobs/b.json");

  
  

var  blob_client3 = container_client.getBlobClient("c.json");

await  blob_client3.downloadToFile("./blobs/c.json");

  
// connection to databse
await  client.connect();

// creating the database

const  databse = client.db("test");

// creating collenctions

const  collection1 = databse.collection("a");

const  collection2 = databse.collection("b");

const  collection3 = databse.collection("c");

  
// Reading files

const  f1 = fs.readFileSync('./blobs/a.json', 'utf-8')

const  f2 = fs.readFileSync('./blobs/b.json', 'utf-8')

const  f3 = fs.readFileSync('./blobs/c.json', 'utf-8')

  
  // creating documents

var  t1 = {

_id:ObjectID("123456789012")

}

  

var  t2 = {

_id:ObjectID("212345678909")

}

  

var  t3 = {

_id:ObjectID("312345678901")

}

  // adding files to documents

t1["file"] = f1;

t2["file"] = f2;

t3["file"] = f3;

  // adding documents to mongodb

collection1.insertOne(t1);

collection2.insertOne(t2);

collection3.insertOne(t3);

  
  

context.res = {

// status: 200, /* Defaults to 200 */

body:  "responseMessage"

};

  
  

}