Python/Boto3/Lamba 中的 AWS DynamoDB 数据为 json 格式
AWS DynamoDB data to json format in Python/Boto3/Lamba
我有一个 DynamoDB table,需要将其转换为 json 格式并使用 Python/Boto3/AWS-Lambda 环境在 API 响应中共享。
userMetrics[
{
"userid": 1234567890, ==> key
"likemetrics": 0,
"lasttimestamp": 1604553995
},
{
"userid": 1234567891, ==> key
"likemetrics": 0,
"lasttimestamp": 1604553998
}]
我正在尝试使用 中提到的示例将整个 DynamoDB table 复制为 json 格式
但在执行时遇到错误
{
"errorMessage": "'dynamodb.Table' object has no attribute 'items'",
"errorType": "AttributeError",
"stackTrace":[
" File \"/var/task/lambda_function.py\", line 75, in lambda_handler\n 'usermetrics': json.dumps(from_dynamodb_to_json(dydb_userTable))\n",
" File \"/var/task/lambda_function.py\", line 7, in from_dynamodb_to_json\n return {k: d.deserialize(value=v) for k, v in item.items()}\n"
]
}
我的 lambda 代码实现:
import json
import boto3
from boto3.dynamodb.types import TypeDeserializer, TypeSerializer
def from_dynamodb_to_json(item):
d = TypeDeserializer()
return {k: d.deserialize(value=v) for k, v in item.items()}
dydb = boto3.resource('dynamodb')
dydb_userTable = dydb.Table('userMetrics')
def lambda_handler(event, context):
return {
'statusCode': 200,
'usermetrics': json.dumps(from_dynamodb_to_json(dydb_userTable))
}
Table
(您代码中的 dydb_userTable
)对象没有您要查找的 items
。您需要在 table 上调用一个方法来为您检索项目,例如 dydb_userTable.scan()
或 dydb_userTable.query()
.
参考:https://boto3.amazonaws.com/v1/documentation/api/latest/reference/services/dynamodb.html#table
我有一个 DynamoDB table,需要将其转换为 json 格式并使用 Python/Boto3/AWS-Lambda 环境在 API 响应中共享。
userMetrics[
{
"userid": 1234567890, ==> key
"likemetrics": 0,
"lasttimestamp": 1604553995
},
{
"userid": 1234567891, ==> key
"likemetrics": 0,
"lasttimestamp": 1604553998
}]
我正在尝试使用
{
"errorMessage": "'dynamodb.Table' object has no attribute 'items'",
"errorType": "AttributeError",
"stackTrace":[
" File \"/var/task/lambda_function.py\", line 75, in lambda_handler\n 'usermetrics': json.dumps(from_dynamodb_to_json(dydb_userTable))\n",
" File \"/var/task/lambda_function.py\", line 7, in from_dynamodb_to_json\n return {k: d.deserialize(value=v) for k, v in item.items()}\n"
]
}
我的 lambda 代码实现:
import json
import boto3
from boto3.dynamodb.types import TypeDeserializer, TypeSerializer
def from_dynamodb_to_json(item):
d = TypeDeserializer()
return {k: d.deserialize(value=v) for k, v in item.items()}
dydb = boto3.resource('dynamodb')
dydb_userTable = dydb.Table('userMetrics')
def lambda_handler(event, context):
return {
'statusCode': 200,
'usermetrics': json.dumps(from_dynamodb_to_json(dydb_userTable))
}
Table
(您代码中的 dydb_userTable
)对象没有您要查找的 items
。您需要在 table 上调用一个方法来为您检索项目,例如 dydb_userTable.scan()
或 dydb_userTable.query()
.
参考:https://boto3.amazonaws.com/v1/documentation/api/latest/reference/services/dynamodb.html#table