【发布时间】:2019-01-17 14:10:21
【问题描述】:
所以我使用 DynamoDB 来存储我的 Spark 作业的状态。我创建了名为 scheduleTime(Partition key) 和 appName(Range key) 的 Primary keys,并且我的 spark 作业在完成后写入作业的状态完全的。在我的 spark 作业完成后,另一个 Python 脚本 计划检索作业状态并在出现故障时重新启动应用程序。我在 DynamoDB 表中没有得到一组特定 主键 的项目,即使记录存在,并且当我使用 UI 时,我可以看到相应的记录。我为此使用 boto3 库 table.get_item() 方法。代码 sn-p 如下:
table.get_item(
Key = {
'scheduleTime': scheduleTime,
'appName': appName
}
)
【问题讨论】:
标签: python amazon-dynamodb boto