java - 如何将 S3object 转换为 Observable

Question

我正在尝试使用 RxJava 和 Vert.x 框架实现一种方法。

该方法有 Observable<String>作为其返回类型，但当从方法 bogy 内的 S3 存储桶获取一些数据时，它返回 S3Object .

现在，我必须隐藏S3Object至Observable<string> 。 (我将 JSON 像 abc.json 一样存储在 S3 存储桶中)。

 public Observable<String> getCustomerFroms3(String orderId) {

    AWSCredentials credentials = new BasicAWSCredentials (
           "*************MIIVCCCA",
            "az4aBUp58x&&&&&&&&&&&&&&&&&&&3gUTw"
    );
    AmazonS3 s3client = AmazonS3ClientBuilder
            .standard()
            .withCredentials(new AWSStaticCredentialsProvider (credentials))
            .withRegion(Regions.AP_SOUTH_1)
            .build();

    String bucketName = "database8";
    S3Object s3Object = s3client.getObject(bucketName,orderId);
    System.out.println(s3Object);

}

我如何转换S3Object至Observable ？

Answer 1

一种简单的方法是使用 Observable 工厂方法从 S3Object 内容创建简单实例:

public Observable<String> getCustomerFroms3(String orderId) {
    return Observable.create(
          s -> {
              try {
                  AWSCredentials credentials = new BasicAWSCredentials (
                        "*************MIIVCCCA",
                        "az4aBUp58x&&&&&&&&&&&&&&&&&&&3gUTw"
                  );
                  AmazonS3 s3client = AmazonS3ClientBuilder
                        .standard()
                        .withCredentials(new AWSStaticCredentialsProvider (credentials))
                        .withRegion(Regions.AP_SOUTH_1)
                        .build();

                  S3Object s3Object = s3client.getObject("database8", orderId);
                  s.onNext(IOUtils.toString(s3Object.getObjectContent()));
                  s.onComplete();
              } catch (Exception e) {
                  s.onError(e);
              }
          }
    );
}

请注意，这只是为了演示创建 Observable 实例的方法，不应被视为最佳选项。