0

我必须进行 api 调用，将压缩文件作为输入传递。我在本地有一个工作示例，但我想在云中移动解决方案。我正在考虑使用 azure blob 存储和 azure 函数触发器。我有以下适用于文件的代码，但我不知道如何在 nodejs 中使用 azure blob 存储和 azure 函数

const zlib = require('zlib');
const fs = require('fs');

const def = zlib.createDeflate();

input = fs.createReadStream('claudio.json')
output = fs.createWriteStream('claudio-def.json')

input.pipe(def).pipe(output)

此代码将文件读取为流，压缩文件并将另一个文件写入流。

我想做的是在任何时候将文件上传到 azure blob 存储容器中时读取文件，然后我想压缩它并保存在具有不同名称的不同容器中，然后进行 API 调用作为输入传递压缩文件保存在另一个容器中

我尝试使用此代码压缩传入文件

const fs = require("fs");
const zlib = require('zlib');
const {Readable, Writable} = require('stream');
module.exports = async function (context, myBlob) {
    context.log("JavaScript blob trigger function processed blob \n Blob:", context.bindingData.blobTrigger, "\n Blob Size:", myBlob.length, "Bytes");
   // const fin = fs.createReadStream(context.bindingData.blobTrigger);
   const def = zlib.createDeflate();
   const s = Readable.from(myBlob.toString())
  context.log(myBlob);
  context.bindings.outputBlob = s.pipe(def)
};

这种方法的问题在于代码的最后一行

  context.bindings.outputBlob = s.pipe(def)

我没有压缩文件，而如果我使用这个

s.pipe(def).pipe(process.stdout)

我可以读取压缩文件

如您在上面看到的，我还尝试使用 fs.createReadStream(context.bindingData.blobTrigger) 包含上传文件的名称和容器名称，但它不起作用

任何想法？谢谢你

4

1 回答 1

0

这是解决方案

var input = context.bindings.myBlob;

var inputBuffer = Buffer.from(input);
var deflatedOutput = zlib.deflateSync(inputBuffer);

context.bindings.myOutputBlob = deflatedOutput;

https://docs.microsoft.com/en-us/answers/questions/500368/compress-and-write-a-file-in-another-container-wit.html

于 2021-08-12T10:39:41.777 回答