- android - 多次调用 OnPrimaryClipChangedListener
- android - 无法更新 RecyclerView 中的 TextView 字段
- android.database.CursorIndexOutOfBoundsException : Index 0 requested, 光标大小为 0
- android - 使用 AppCompat 时,我们是否需要明确指定其 UI 组件(Spinner、EditText)颜色
使用AWS DataPipeline API ,我正在尝试以编程方式评估 Expression像下面这样:
sometext-#{format(@scheduledStartTime, 'YYYYMMddHHmmss')
为了计算表达式,我使用了如下所示的 PipelineObject
:
Id:@MyPipelineObject_2018-08-26T01:00:00
Name:@MyPipelineObject_2018-08-26T01:00:00
- Key:@scheduledStartTime
- StringValue:2018-08-26T01:00:00
- Key:@scheduledEndTime
- StringValue:2018-08-27T01:00:00
如果我知道 pipelineId 和 pipelineObjectId,如何计算表达式?我正在使用Java AWS SDK ,并创建一个 EvaluateExpressionRequest
,如下所示:
String expressionToBeEvaluated = "sometext-#{format(@scheduledStartTime, 'YYYYMMddHHmmss')";
String myPipelineObjectId = "@MyPipelineObject_2018-08-26T01:00:00";
EvaluateExpressionRequest evaluateExpressionRequest = new EvaluateExpressionRequest()
.withPipelineId(myPipelineId)
.withExpression(expressionToBeEvaluated)
.withObjectId(myPipelineObjectId);
但是,从文档中我不清楚如何使用 EvaluateExpressionRequest
对象实际发出请求。我看过EvaluateExpressionResult
但 setEvaluatedExpression
方法仅接受 String
作为输入。
我是否做错了什么,遗漏了一些基本的东西,或者 SDK 只是不支持我想要做的事情?
任何意见或建议将不胜感激。谢谢!
最佳答案
所以我在发布问题后几分钟就弄清楚了。事实证明答案非常简单,而且我已经研究这个东西太久了。 DataPipeline
对象具有方法 evaluateExpression()
它接受 EvaluateExpressionRequest
并返回 EvaluateExpressionResult
。您可以通过对返回的对象调用 getEvaluatedExpression
来获取计算结果。
EvaluateExpressionRequest evaluateExpressionRequest = new EvaluateExpressionRequest()
.withPipelineId(myPipelineId)
.withExpression(expressionToBeEvaluated)
.withObjectId(myPipelineObjectId);
dataPipeline.evaluateExpression(evaluateExpressionRequest).getEvaluatedExpression(); //evaluates to sometext-20180826010000
希望对有类似困扰的人有帮助!
关于java - 使用 Java SDK 的 AWS DataPipeline EvaluateExpression,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/52029051/
当我尝试创建具有这些属性的 EMRcluster 资源时: Emr 托管主安全组 ID Emr 托管从属安全组 ID 我遇到此错误:因错误而终止。如果您使用自定义安全性,还必须指定 ServiceAc
我是 AWS 数据管道的新手。我创建了一个成功的数据管道,将所有内容从 RDS 提取到 S3 存储桶。一切正常。我在 S3 存储桶中看到我的 .csv 文件。但是我在我的表中存储了西类牙名字,在 cs
我正在尝试使用RedShiftCopyActivity和datapipeline将一堆csv文件从S3复制到Redshift。 只要csv结构与表结构匹配,此方法就可以正常工作。在我的情况下,csv的
使用AWS DataPipeline API ,我正在尝试以编程方式评估 Expression像下面这样: sometext-#{format(@scheduledStartTime, 'YYYYMM
我试图以编程方式从 azure 函数调用数据工厂管道。它抛出以下错误。 link: http://eatcodelive.com/2016/02/24/starting-an-azure-data-f
当通过 API/CLI 创建数据管道来创建 EmrCluster 时,我可以使用数组结构指定多个步骤: { "objects" : [ { "id" : "myEmrCluster", "te
我有一个简单的 DataPipeline 作业,它只有一个 EmrActivity 和一个尝试从我的 s3 存储桶执行配置单元脚本的步骤。 EmrActivity 的配置如下所示: { "name
我尝试使用 Athena JDBC 连接在 AWS 数据管道中运行 sqlactivity,但是在运行管道时出现“UnsupportedClassVersionError”错误。 我从博客(http:
我正在尝试部署 Export DynamoDB Table to S3通过 Cloudformation 生成模板,但从 Cloudformation 获取 type is not Defined i
我有一个包含约 16M 条记录的 DynamoDB,其中每条记录的大小为 4k。该表配置为自动缩放目标利用率:70%,读取的最小配置容量:250 和写入的最大配置容量:3000。 我正在尝试设置数据管
我是一名优秀的程序员,十分优秀!