本文属于机器翻译版本。若本译文内容与英语原文存在差异,则一律以英文原文为准。
创建此函数后,可以通过使用 AWS CLI将新记录添加到数据流来测试它:
aws kinesis put-record --stream-name test --data "My test data." --partition-key partitionKey1 --region
us-west-1
然后使用 OpenSearch 服务控制台或 OpenSearch 仪表板验证是否lambda-kine-index
包含文档。还可使用以下请求:
GET https://domain-name
/lambda-kine-index/_search
{
"hits" : [
{
"_index": "lambda-kine-index",
"_type": "_doc",
"_id": "shardId-000000000000:49583511615762699495012960821421456686529436680496087042",
"_score": 1,
"_source": {
"timestamp": 1523648740.051,
"message": "My test data.",
"id": "shardId-000000000000:49583511615762699495012960821421456686529436680496087042"
}
}
]
}