将 API 文件下载到 Firebase 云存储？

Question

如何将 IBM Watson Text-to-speech 中的音频文件（大约 10K）保存到 Firebase Cloud Storage？这是我的代码，复制自 IBM Watson documentation：

const functions = require('firebase-functions');
const admin = require('firebase-admin');
admin.initializeApp();

var TextToSpeechV1 = require('watson-developer-cloud/text-to-speech/v1');
var fs = require('fs');    

exports.TextToSpeech = functions.firestore.document('Test_Value').onUpdate((change, context) => {

  var textToSpeech = new TextToSpeechV1({
    username: 'groucho',
    password: 'swordfish',
    url: 'https://stream.watsonplatform.net/text-to-speech/api'
  });

  var synthesizeParams = {
    text: 'Hello world',
    accept: 'audio/wav',
    voice: 'en-US_AllisonVoice'
  };

  textToSpeech.synthesize(synthesizeParams).on('error', function(error) {
    console.log(error);
  }).pipe(fs.createWriteStream('hello_world.wav')); // what goes here?

  const file = ?????
  file.download()
  .then(function(data) {
    console.log("File downloaded."
  })
  .catch(error => {
    console.error(error);
  });
});

缺少的代码在之间

}).pipe(fs.createWriteStream('hello_world.wav'));

和

file.download()

不知何故，我必须将 IBM Watson 提供的文件转换为 Firebase Cloud Storage 可识别的文件。 fs 不允许在 Google Cloud Functions 中使用吗？

另外，第 6 行不应该是

var fs = require('fs-js');

不是

var fs = require('fs'); 

根据NPM，fs 包已弃用。

Google Cloud Functions 中是否允许使用 pipe？如果是这样，我将文件传送到什么？我需要看起来像这样的东西：

}).pipe(file);
file.download()

Answer 1

好的，查看file.download() 的文档，我认为您只需对代码稍作改动即可完成这项工作。 file 需要输入来自 Google Storage 库的 File（您需要安装 this library）。这种类型有一个名为createWriteStream 的方法，您可以将synthesize 的结果流式传输到该方法。我没有对此进行测试，但我相信它应该是正确的，或者至少应该为您指明正确的方向：

// looks like you'll need to require this package also
const { Storage } = require('@google-cloud/storage');

const functions = require('firebase-functions');
const admin = require('firebase-admin');
admin.initializeApp();

var TextToSpeechV1 = require('watson-developer-cloud/text-to-speech/v1');
var fs = require('fs');    

const storage = new Storage();
const myBucket = storage.bucket('my-bucket');

exports.TextToSpeech = functions.firestore.document('Test_Value').onUpdate((change, context) => {

  var textToSpeech = new TextToSpeechV1({
    username: 'groucho',
    password: 'swordfish',
    url: 'https://stream.watsonplatform.net/text-to-speech/api'
  });

  var synthesizeParams = {
    text: 'Hello world',
    accept: 'audio/wav',
    voice: 'en-US_AllisonVoice'
  };

  const file = myBucket.file('my-file'); // name your file something here

  textToSpeech
    .synthesize(synthesizeParams)
    .on('error', function(error) {
      console.log(error);
    })
    .pipe(file.createWriteStream()) // the File object has a `createWriteStream` method for writing streams to it
    .on('error', function(err) {
      console.log(err);
    })
    .on('finish', function() {
      // The file upload is complete.
      file.download()
        .then(function(data) {
          console.log("File downloaded.");
        })
        .catch(error => {
          console.error(error);
        });
    });
});

记录在案：

• pipe() 应该在 Google Cloud Functions 中被允许并且它是异步的。这就是为什么您需要在下载文件之前监听finish 事件
• fs 仅在公共 NPM 上被弃用，但这不是您要导入的包，fs（文件系统）模块是 Node's core built-in packages 之一。也就是说，您的代码中似乎根本不需要它

Answer 2

谢谢dpopp07，我明白了！

exports.TextToSpeech = functions.firestore.document('Test_Word').onUpdate((change, context) => {

if (change.after.data().word != undefined) {
    myWord = change.after.data().word;
    myWordFileType = myWord + '.ogg';

  var synthesizeParams = {
        text: myWord,
        accept: 'audio/ogg',
        voice: 'en-US_AllisonVoice'
      };

      const {Storage} = require('@google-cloud/storage');
      const storage = new Storage();
      const bucket = storage.bucket('myapp.appspot.com');
      const file = bucket.file('Test_Folder' + myWordFileType);

      var TextToSpeechV1 = require('watson-developer-cloud/text-to-speech/v1');

      var textToSpeech = new TextToSpeechV1({
        username: 'groucho',
        password: 'swordfish',
        url: 'https://stream.watsonplatform.net/text-to-speech/api'
      });

      textToSpeech.synthesize(synthesizeParams).on('error', function(error) {
        console.log(error);
      }).pipe(file.createWriteStream({contentType: 'auto'}))
      .on('error', function(err) {})
      .on('finish', function() {
        console.log("Complete.");
      });
      }
      return 0;
    });

当一个新单词被写入 Firestore 位置时，该函数会触发，然后提取该单词并将其命名为 myWord。添加 .ogg 会生成 myWordFileType。这些函数向 IBM Watson Text-to-speech 发送一个 HTTP 请求，它返回一个回调，而不是一个承诺，所以代码有点难看。关键是 HTTP 响应通过 Node 命令pipe 将文件发送到 Google Cloud Storage 命令file.createWriteStream。 contentType 必须设置为获得可读文件，但auto 使这变得容易。然后将该文件写入存储桶，该存储桶设置为我的 Firebase Cloud Storage 文件夹Test_Folder，文件名为myWordFileType。