如何将cloudwatch指标数据发送到kinesis数据流

import boto3

def lambda_handler(event, context):
    cw = boto3.client('cloudwatch')
    kinesis = boto3.client('kinesis')

    # 获取指标数据
    response = cw.get_metric_data(
        MetricDataQueries=[
            {
                'Id': '1',
                'MetricStat': {
                    'Metric': {
                        'Namespace': 'YourNamespace',
                        'MetricName': 'YourMetricName',
                        'Dimensions': [
                            {
                                'Name': 'YourDimensionName',
                                'Value': 'YourDimensionValue'
                            },
                        ]
                    },
                    'Period': 300,
                    'Stat': 'Average',
                    'Unit': 'Count'
                },
            },
        ],
        StartTime='2022-01-01T00:00:00Z',
        EndTime='2022-01-02T00:00:00Z',
        ScanBy='TimestampDescending'
    )

    # 将指标数据发送到Kinesis数据流
    response = kinesis.put_record(
        StreamName='YourKinesisStream',
        Data=response,
        PartitionKey='YourPartitionKey'
    )

    return {
        'statusCode': 200,
        'body': 'Data sent to Kinesis stream successfully'
    }