将botocore.response.StreamingBody对象推送到消防软管输送流

Question

我有一个S3存储桶，其中包含源记录，我正在进行一些手动回填，因此我尝试编写一个python脚本，将它们发送到Firehose交付流。这些文件的类型是botocore.response.StreamingBody对象，并且是非常直接、简单的JSON。我一直在研究的代码如下：

import os
import boto3
import json

FirehoseClient = boto3.client('firehose','us-east-1')
S3Client = boto3.client('s3','us-east-1')
prefix = 'source_records/2019/08/21/'

keys = []
for i in range(len(all_objects['Contents'])):
    keys.append(all_objects['Contents'][i]['Key'])

test_object = S3Client.get_object(Bucket = 'iv-scan-data', Key = keys[0])

t = test_object['Body']

从这里我想调用函数put_record_batch（），但我不确定如何将对象['Body']传递到函数中。boto3文档并不是非常有用