javascript - 将响应式(Reactive)编程 RXJS 与适用于 JavaScript 的 AWS 开发工具包结合使用

Question

我正在使用适用于 javascript 的 aws sdk 将对象上传到 S3 存储桶，而且还使用响应式(Reactive)编程 rxjs 来创建流。那么，以流的形式执行 S3 上传然后以流的形式触发 API 调用的最佳方法是什么？

var stream = Rx.Observable.fromPromise(s3.putObject(params).promise());
stream.subscribe(data=>{},err=>{})

在上面的示例中，它有效，但问题是“数据”是一个空对象，即使在文件成功上传到 S3 存储桶后也是如此，所以我无法执行 API 流，因为我需要一些文件信息。

或者我应该使用 Rx.Observable.fromNodeCallback(s3.upload)？请指教，非常感谢。

Answer 1

您可以从回调中创建 Observable 流，而无需创建中间 promise 。如果你想得到文件的详细信息，请尝试使用 upload method aws-sdk:

const upload = s3.upload(config);
const upload$ = Rx.Observable.fromNodeCallback(upload.send, upload)();
upload$.subscribe(v => console.log(v)); // will print file details