无法在简单的情况下使Akka流/ alpakka S3正常工作

问题描述

我正在做我认为很简单的事情来检查alpakka是否正常工作：

val awsCreds = AwsBasicCredentials.create("xxx","xxx")
val credentialsProvider = StaticCredentialsProvider.create(awsCreds)
implicit val staticCreds = S3Attributes.settings(S3Ext(context.system).settings.withCredentialsProvider(credentialsProvider)
  .withS3RegionProvider(new AwsRegionProvider {val getRegion: Region = Region.US_EAST_2}))

val d = S3.checkIfBucketExists(action.bucket)
d foreach { msg => log.info("mgs: " + msg.toString)}

运行此命令我会得到

 msgs: NotExists

但是action.bucket所引用的存储桶确实存在，我可以使用这些凭据来访问它。此外，当我修改凭据（通过更改密钥）时，会收到相同的消息。根据{{​​3}}，我应该得到的是AccessDenied。

我之所以说到这一点，是因为我认为环境并没有采用正确的凭据-因此所有硬编码的值都没有。但是现在我真的不知道是什么原因引起的。

谢谢

更新：操作对象只是一个由桶和路径组成的案例类。我已经在调试中检查到action.bucket和action.path指向它们应该是的东西-在这种情况下为S3存储桶。我还尝试了上面的代码，只是用字符串存储桶名称代替了action.bucket。

解决方法

只是我的粗心。 。

错误的副本为混合添加了额外的隐式系统。在akka 2.6中对隐式实现器进行了一些更改，我认为这些更改以及额外的隐式actor系统导致了奇怪的混合。