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) – 記錄列表

此條目是否有幫助？