当AWS Kinesis Firehose未响应Lambda函数时,可能有几个原因导致此问题。下面是一些可能的解决方法和代码示例:
import boto3
def lambda_handler(event, context):
region = boto3.session.Session().region_name
print(region)
firehose:PutRecordBatch权限来实现。以下是一个示例策略:{
"Version": "2012-10-17",
"Statement": [
{
"Effect": "Allow",
"Action": "firehose:PutRecordBatch",
"Resource": "arn:aws:firehose:region:account-id:deliverystream/stream-name"
}
]
}
import boto3
def lambda_handler(event, context):
firehose = boto3.client('firehose')
response = firehose.describe_delivery_stream(
DeliveryStreamName='stream-name'
)
print(response['DeliveryStreamDescription']['Destinations'])
import boto3
import base64
def lambda_handler(event, context):
client = boto3.client('logs')
response = client.get_log_events(
logGroupName='/aws/lambda/function-name',
logStreamName='yyyy/mm/dd/[LATEST]',
startFromHead=True
)
for event in response['events']:
print(base64.b64decode(event['message']))
以上是一些可能的解决方法和代码示例,可以根据具体情况进行调整和修改。