ecs_composex.kinesis package ¶
Submodules ¶
ecs_composex.kinesis.kcl_helpers module ¶
Module to help with KCL IAM Permissions configuration to the services
- ecs_composex.kinesis.kcl_helpers. add_cloudwatch_metric_data_permission ( family ) [source] ¶
-
Adds permissions to publish metrics data to CloudWatch
- Return type :
-
None
ecs_composex.kinesis.kinesis_kinesis_firehose module ¶
Updates x-kinesis_firehose fields and properties, IAM policies for Firehose::DeliveryStream
- ecs_composex.kinesis.kinesis_kinesis_firehose. kinesis_to_firehose ( resource , dest_resource , dest_resource_stack , settings ) [source] ¶
-
Updates :type resource: :param resource: :type dest_resource: :param dest_resource: :type dest_resource_stack: :param dest_resource_stack: :type settings:
ecs_composex.common.settings.ComposeXSettings
:param settings: :rtype:None
:return:
ecs_composex.kinesis.kinesis_module module ¶
ecs_composex.kinesis.kinesis_params module ¶
ecs_composex.kinesis.kinesis_stack module ¶
Module to handle import/create AWS Kinesis Data Streams
- class ecs_composex.kinesis.kinesis_stack. Stream ( name , definition , module , settings ) [source] ¶
-
Bases:
ApiXResource
Class to represent a Kinesis Stream
- handle_x_dependencies ( settings , root_stack ) [source] ¶
-
Updates other resources and replace the values for x-kinesis wherever applicable.
- Parameters :
-
-
settings (
ecs_composex.common.settings.ComposeXSettings
) – -
root_stack (
ecs_composex.common.stacks.ComposeXStack
) –
-
- Return type :
-
None
- Returns :
-
- class ecs_composex.kinesis.kinesis_stack. XStack ( title , settings , module , ** kwargs ) [source] ¶
-
Bases:
ComposeXStack
Class to represent Kinesis Data Streams stack
- do_validation : bool ¶
- properties : Dict[str, Any] ¶
- propnames : Set[str] ¶
- resource : Dict[str, Any] ¶
- template : Optional[Template] ¶
- title : Optional[str] ¶
ecs_composex.kinesis.kinesis_template module ¶
- ecs_composex.kinesis.kinesis_template. create_new_stream ( stream ) [source] ¶
-
Function to create the new Kinesis stream :param ecs_composex.kinesis.kinesis_stack.Stream stream: :param ecs_composex.common.settings.ComposeXSettings settings: :return:
- ecs_composex.kinesis.kinesis_template. create_streams_template ( new_resources , settings ) [source] ¶
-
Function to create the root template for Kinesis streams
- Parameters :
-
-
new_resources ( list<ecs_composex.kinesis.kinesis_stack.Stream> ) –
-
settings ( ecs_composex.common.settings.ComposeXSettings ) –
-
- Returns :
-