在播放java项目中使用Alpakka库从s3下载文件中的问题

如何解决在播放java项目中使用Alpakka库从s3下载文件中的问题

我已使用 alpakka 成功将 csv 文件上传到 s3，现在我尝试也使用 alpakka 下载该文件。但无法完全下载该 csv 文件，有时返回 10 行，有时返回 5 行，有时返回 50 15413 行。 看起来它没有等待所有记录

final Source<Optional<Pair<Source<ByteString,NotUsed>,ObjectMetadata>>,NotUsed>
    sourceAndMeta = S3.download(bucket(),bucketKey());
final Pair<Source<ByteString,ObjectMetadata> dataAndMetadata =
    sourceAndMeta
        .runWith(Sink.head(),system)
        .toCompletableFuture()
        .get(5,TimeUnit.SECONDS)
        .get();

final Source<ByteString,NotUsed> data = dataAndMetadata.first();
final ObjectMetadata Metadata = dataAndMetadata.second();

final CompletionStage<String> resultCompletionStage =
    data.map(ByteString::utf8String).runWith(Sink.head(),system);

String result = resultCompletionStage.toCompletableFuture().get(5,TimeUnit.SECONDS);