使用适用于 Android 的 AWS Amplify 下载多个文件

Question

我正在构建一个 Android 应用，它使用 AWS Amplify 从 S3 列出和下载文件。

示例代码显示下载是异步的：

Amplify.Storage.downloadFile()
    "ExampleKey",
    new File(getApplicationContext().getFilesDir() + "/download.txt"),
    result -> Log.i("MyAmplifyApp", "Successfully downloaded: " + result.getFile().getName()),
    error -> Log.e("MyAmplifyApp",  "Download Failure", error)
);

我希望在后台线程中下载（可能很多）文件，并在所有文件下载完毕（或发生错误）后通知主线程。问题：

实现此功能的最佳方法是什么？

附： 我试过RxAmplify，它暴露了RxJava Observables，我可以在上面调用blockingSubscribe()。但是，绑定是非常新的，使用它时我遇到了一些应用程序崩溃未捕获的异常。

Answer 1

使用香草放大

downloadFile() 将在后台线程上执行其工作。只需使用 standard approaches 之一从回调返回主线程：

Handler handler = new Handler(context.getMainLooper());
File file = new File(context.getFilesDir() + "/download.txt");

Amplify.Storage.downloadFile(
    "ExampleKey", file,
    result -> {
        handler.post(() -> {
            Log.i("MyAmplifyApp", "Successfully downloaded: " + result.getFile().getName());
        });
    },
    error -> Log.e("MyAmplifyApp",  "Download Failure", error)
);

使用 Rx 绑定

但就个人而言，我会使用 Rx 绑定。 The official documentation 包括用于 Rx API 的 sn-ps。这是一个更量身定制的示例：

File file = new File(context.getFilesDir() + "/download.txt");
RxAmplify.Storage.downloadFile("ExampleKey", file)
    .subscribeOn(Schedulers.io())
    .observeOn(AndroidSchedulers.mainThread())
    .subscribe(result -> {
        Log.i("RxExample", "Download OK.");
    }, failure -> {
        Log.e("RxExample", "Failed.", failure);
    });

并行运行多个下载

通过调用RxAmplify.Storage.downloadFile("key", local) 构建Singles 的集合。然后，使用Single.mergeArray(...) 将它们全部组合起来。订阅它，方法同上。

RxStorageCategoryBehavior storage = RxAmplify.Storage;
Single
    .mergeArray(
        storage.downloadFile("one", localOne)
            .observeResult(),
        storage.downloadFile("two", localTwo)
            .observeResult()
    )
    .subscribeOn(Schedulers.io())
    .observeOn(AndroidSchedulers.mainThread())
    .subscribe(/* args ... */);

报告错误

您提到您遇到了意外的异常。如果是这样，请提交错误here，我会修复它。