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

此模块包含 AWS Firehose Hook。

模块内容¶

类¶

与 Amazon Kinesis Firehose 交互。

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

基类：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

put_records(records)[源代码]¶

将批量记录写入 Kinesis Firehose。

另请参阅

Firehose.Client.put_record_batch()

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

此条目是否有帮助？