首页 文章

清理临时目录Firebase Cloud 功能

提问于
浏览 次
0

我正在为我的webapp使用Cloud Functions for Firebase . 我需要为在Firebase存储上上传的任何图片创建缩略图 . 为此，我需要将上传的文件从GCS存储桶下载到临时目录（使用 mkdirp-promise ），然后应用 imageMagick 命令创建缩略图 . （Firebase Function Samples- Generate Thumbnail）

return mkdirp(tempLocalDir).then(() => {
    console.log('Temporary directory has been created', tempLocalDir);
    // Download file from bucket.
    return bucket.file(filePath).download({
      destination: tempLocalFile
    });
  }).then(() => {
    //rest of the program
  });
});

我的问题是：

  • 这个 temp 目录在哪里创建？

  • 此临时存储是否计入我的Firebase Cloud 存储或Google Cloud 存储配额？

  • 成功上传新创建的缩略图文件后，如何清理临时目录？所以我的配额不会超过 .

firebase firebase-storage google-cloud-functions

2 回答

  • 4
    回复于
  • 2

    以下是我为Google I / O中的“Fire！sale”持续部署演示编写的一些代码（警告：它是TypeScript，而不是JavaScript . 这让我可以使用更容易阅读的await / async，特别是在错误处理）

    import * as fs from 'fs';
import * as os from 'os';
import * as path from 'path';
let tempy = require('tempy'); // No .d.ts

function rmFileAsync(file: string) {
  return new Promise((resolve, reject) => {
    fs.unlink(file, (err) => {
      if (err) {
        reject(err);
      } else {
        resolve();
      }
    })
  })
}

function statAsync(file: string): Promise<fs.Stats> {
  return new Promise((resolve, reject) => {
    fs.stat(file, (err, stat) => {
      if (err) {
        reject(err);
      } else {
        resolve(stat);
      }
    })
  })
}

async function rmrfAsync(dir: string) {
  // Note: I should have written this to be async too
  let files = fs.readdirSync(dir);

  return Promise.all(_.map(files, async (file) => {
    file = path.join(dir, file);
    let stat = await statAsync(file);
    if (stat.isFile()) {
      return rmFileAsync(file);
    }
    return rmrfAsync(file);
  }));
}

    然后在我的Cloud Functions代码中，我可以执行以下操作：

    export let myFunction = functions.myTrigger.onEvent(async event => {
  // If I want to be extra aggressive to handle any timeouts/failures and
  // clean up before execution:
  try {
    await rmrfAsync(os.tmpdir());
  } catch (err) {
    console.log('Failed to clean temp directory. Deploy may fail.', err);
  }

  // In an async function we can use try/finally to ensure code runs
  // without changing the error status of the function.
  try {
    // Gets a new directory under /tmp so we're guaranteed to have a
    // clean slate.
    let dir = tempy.directory(); 
    // ... do stuff ...
  } finally {
    await rmrfAsync(dir);
  }
}
    回复于

相关问题