airflow.providers.amazon.aws.hooks.kinesis¶

此模块包含 AWS Firehose hook。

类¶

与 Amazon Kinesis Firehose 交互。

模块内容¶

class airflow.providers.amazon.aws.hooks.kinesis.FirehoseHook(delivery_stream, *args, **kwargs)[source]¶

基类: airflow.providers.amazon.aws.hooks.base_aws.AwsBaseHook

与 Amazon Kinesis Firehose 交互。

提供 boto3.client("firehose") 的厚层包装。

参数:: delivery_stream (str) – 传输流的名称

可以指定附加参数（例如 aws_conn_id），这些参数会传递给底层的 AwsBaseHook。

另请参阅

airflow.providers.amazon.aws.hooks.base_aws.AwsBaseHook

delivery_stream[source]¶

put_records(records)[source]¶

将批量记录写入 Kinesis Firehose。

另请参阅

Firehose.Client.put_record_batch()

参数:: records (collections.abc.Iterable) – 记录列表

此条目是否有帮助？