要使用AWS EventBridge的事件模式来插入OpenSearch文档,你可以按照以下步骤进行操作:
import boto3
def lambda_handler(event, context):
# 解析EventBridge事件中的数据
data = event['detail']
# 初始化OpenSearch的boto3客户端
client = boto3.client('es')
# 构建要插入的文档数据
document = {
'index': 'your-index-name',
'body': {
'field1': data['field1'],
'field2': data['field2'],
# 添加其他字段...
}
}
# 插入文档到OpenSearch
response = client.index(**document)
# 输出插入结果
print(response)
{
"source": ["your-event-source"],
"detail-type": ["your-event-type"],
"detail": {
"field1": ["value1"],
"field2": ["value2"]
// 添加其他字段...
}
}
这样,当符合事件模式条件的事件发生时,EventBridge将触发Lambda函数,Lambda函数将解析事件数据并插入到OpenSearch中。