我正在努力下载以直接流式传输到 GCS,而不保存到文件系统,请参阅下面的代码片段。
const { Storage } = require('@google-cloud/storage');
const http = require('http');
const storage = new Storage();
const fs = require("fs");
const bucketName = 'BUCKETNAMEHERE';
const blobName = 'image.jpg';
const bucket = storage.bucket(bucketName);
const blob = bucket.file(blobName);
const streamDownload = () => {
http.get("http://i3.ytimg.com/vi/J---aiyznGQ/mqdefault.jpg")
.pipe(blob.createWriteStream({
metadata: {
contentType: 'image/jpg'
}
}))
.on("error", (err) => {
console.error(`error occurred`);
})
.on('finish', () => {
console.info(`success`);
});
};
完成时永远不会触发。没有任何输出。 我可以毫无问题地将 http.get 流式传输到本地文件,因此该部分似乎没问题。
同样有效的方法是从本地文件系统流式传输到 GCS,如下所示:
const streamFs = () => {
fs.createReadStream('/path/to/mqdefault.jpg')
.pipe(blob.createWriteStream({
metadata: {
contentType: 'image/jpg'
}
}))
.on("error", (err) => {
console.error(`error occurred`);
})
.on('finish', () => {
console.info(`success`);
});
};
第二个片段记录“成功”并且文件存在于存储桶中。
http.get
和 fs.createReadStream
都创建一个读取流。
我在这里做错了什么?
最佳答案
请求库与 Promise 一起工作,而 http 库需要回调:
const streamDownload = () => {
var stream = blob.createWriteStream({
metadata: {
contentType: 'image/jpg'
}
})
http.get("http://i3.ytimg.com/vi/J---aiyznGQ/mqdefault.jpg", function(res){
stream.on("error", (err) => {
console.error(`error occurred`);
})
stream.on('finish', () => {
console.info(`success`);
});
res.pipe(stream)
})
}
关于node.js - 通过http下载并使用nodejs流式上传到Google Cloud存储,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/54014305/