问题标签 [aws-java-sdk]

我想开发 java 应用程序并部署在 EC2 上。据我了解，您应该使用角色而不是访问密钥和密钥。

现在假设我启动了一个实例，并附加了一个 S3 完全访问角色，那么我将如何进行 API 调用？

因为对于 SDK，它需要访问密钥和密钥，如下所示：

我不明白它将如何工作？

我已将 IAM 角色附加到我的实例 - myRole。我已将其AmazonS3FullAccess策略附加到 myRole。我使用上面的代码使用 SDK 获取与 myRole 关联的策略，但是当我尝试获取策略时遇到 NoSuchEntity 异常。我能够获取角色名称，并且我的输出是 myRole，但是当我尝试获取策略详细信息时遇到错误。

我不知道为什么。
我在这里做错了什么？

我正在尝试为 QA 团队开发一个 UI，他们可以在其中检查队列消息而无需登录 AWS。

为了使这个 UI 更便宜，我只显示前十个队列消息，现在如果 QA 人员在分析队列 masseges 后想要获取更多记录怎么办。

如何在不使用可见性超时选项的情况下从队列中获取接下来的 10 条消息？

我正在开发一个 AWS CloudFormation 管理平台，该平台允许用户在 CloudFormation 上启动、更新和删除堆栈。

启动堆栈时，我创建一个数据库条目以将其与模板（要创建的资源集合）和客户相关联。用户可以调用和查看他们堆​​栈中发生的最新事件，即“CREATION_IN_PROGRESS”、“CREATION_COMPLETED”。

目前，当一个堆栈被删除时，我会立即将其从数据库中删除，除了“您的堆栈正在被删除”之外，不会向用户提供更多信息。

deleteStack()一旦启动堆栈删除，执行 a 时当前可用的回调已经返回。

我想在删除它时提供更多信息和事件，当堆栈完全删除时，将其从我的数据库中删除。

实现这一点的唯一方法是执行一个函数以在定时间隔内检查堆栈的存在，一旦它消失，就将其从数据库中删除。

我的假设是错误的，还是有人读过这篇文章有更好的想法或实施？

欢迎任何信息。

http://docs.aws.amazon.com/general/latest/gr/api-retries.html

该文档提到“每个 AWS SDK 实现自动重试逻辑，AWS SDK for Java 自动重试请求。”

如果我没有指定任何重试配置，Java AWS SDK 的默认机制是什么？我一直在使用 Java AWS SDK，如果 AWS 服务端出现故障，我会得到一个简单的服务异常。我从未体验过任何“自动”重试机制。有人能解释一下这个重试机制是什么吗？

如何使用 aws-java-sdk 获取某个区域的所有可用图像列表，我刚刚尝试使用以下代码，它会持续执行很长时间。

我的目标是从 S3 获取对象（图像），更改文件的元数据，并将其替换为已更改元数据的新文件。

为了更改元数据，我正在使用commonsimaging library。我已经对下面的示例进行了编码，该示例按预期工作，但不处理 S3。

以上工作，因为我可以运行exiftool并newimage2.jpg查看设置的元数据属性：

问题

如何使用 AWS S3 SDK 使用 S3 上的对象执行相同操作？上述updateXmpXml方法需要OutputStream作为第二个参数。但是，我在 AWS sdk http://docs.aws.amazon.com/AWSJavaSDK/latest/javadoc/allclasses-noframe.html中看不到任何输出流类

我的目标是：

1. 从 S3 读取文件，
2. 更改其元数据
3. 再次将其推送到 S3

AWS java SDK 不允许推送输出流。因此，我必须将outputstreamstep2 转换为inputstream. 为此，我决定使用PipedInputStream.

但是，我的代码只是挂在writeTo(out);步骤中。此代码位于 grails 应用程序中。当代码挂起时，CPU 不处于高消耗状态：

上面的代码只是打印starting writeto和挂起。它不打印ending writeto

更新 通过将文件放在writeTo一个单独的线程中，文件现在被写入 S3，但是，只有 1024 个字节被写入。文件不完整。如何编写从输出流到 S3 的所有内容？

我有一个 JSON 格式的 AWS 数据管道定义

使用 Java SDK 我创建了一个空管道，现在我想使用我的 JSON 来放置管道定义。基本上我想创建一个 PutPipelineDefinitionRequest （http://docs.aws.amazon.com/AWSJavaSDK/latest/javadoc/com/amazonaws/services/datapipeline/model/PutPipelineDefinitionRequest.html）而不一一创建 PipelineObjects 。

我怎样才能做到这一点？可能吗？

谢谢！

我遇到了构建问题。这是我的 sbt 文件：

这是我看到的完整错误消息：

这是我正在尝试使用的导入：

如何com.amazonaws.auth.profile.ProfileCredentialsProvider在 Scala 中导入？

编辑

更改 sbt 文件，使 spark core 版本对应 Scala 版本，新内容：