kafka_overwatch.aws_helpers package ¶

Submodules ¶

kafka_overwatch.aws_helpers.kafka_client_secrets module ¶

Parses the configuration given to the configuration file and is interpolated with the values from {{resolve}}

kafka_overwatch.aws_helpers.kafka_client_secrets. eval_kafka_client_config ( kafka_cluster ) [source] ¶

If a configuration value is a string starting with {{resolve:}} the value is interpolated using AWS SecretsManager or AWS SSM. We create a new dict in order to preserve the original

Return type :: dict

kafka_overwatch.aws_helpers.kafka_client_secrets. handle_librdkafka_config ( kafka_cluster ) [source] ¶

Return type :: dict

kafka_overwatch.aws_helpers.s3 module ¶

class kafka_overwatch.aws_helpers.s3. S3Handler ( s3_output_config ) [source] ¶

Bases: object

property client ¶: Ensures to get client with a fresh session if needed

property config : S3Output ¶

property session : Session ¶

upload ( body , file_name , mime_type = None ) [source] ¶

Return type :: typing.Optional [ str ]

Module contents ¶

AWS Helper functions

kafka_overwatch.aws_helpers. get_session_from_iam_override ( iam_override ) [source] ¶

Returns a boto3 session from the IamOverride config. If profileName is set, return session for that profile name Elif profileName + AssumeRole, use a session of that profile name, then return AssumeRole session Elif not profileName and AssumeRole, just use AssumeRole

Return type :: boto3.session.Session