验证录入事件流

创建订阅筛选器后，“ CloudWatch 日志” 会将所有与过滤器模式匹配的传入日志事件转发到 Kinesis Data Firehose 传输流。根据 Kinesis Data Firehose 传输流上设置的时间缓冲间隔，数据将开始显示在您的 Amazon S3 存储桶中。经过足够的时间后，您可以通过检查 Amazon S3 存储桶来验证您的数据。要检查存储桶，请输入以下命令：

aws s3api list-objects --bucket 'firehose-test-bucket1' 

该命令的输出将与以下内容类似：

{
    "Contents": [
        {
            "Key": "2021/02/02/08/my-delivery-stream-1-2021-02-02-08-55-24-5e6dc317-071b-45ba-a9d3-4805ba39c2ba",
            "LastModified": "2021-02-02T09:00:26+00:00",
            "ETag": "\"EXAMPLEa817fb88fc770b81c8f990d\"",
            "Size": 198,
            "StorageClass": "STANDARD",
            "Owner": {
                "DisplayName": "firehose+2test",
                "ID": "EXAMPLE27fd05889c665d2636218451970ef79400e3d2aecca3adb1930042e0"
            }
        }
    ]
}

然后，您可以通过输入以下命令，从存储桶中检索特定对象。将 key 的值替换为您在上一个命令中找到的值。

aws s3api get-object --bucket 'firehose-test-bucket1' --key '2021/02/02/08/my-delivery-stream-1-2021-02-02-08-55-24-5e6dc317-071b-45ba-a9d3-4805ba39c2ba' testfile.gz

Amazon S3 对象中的数据以 gzip 格式压缩。您可使用以下命令之一检查命令行中的原始数据：

Linux：

zcat testfile.gz

macOS：

zcat <testfile.gz