带有AWS会话管理的AWS Kinesis logger streamhandler
kinesis-logger-streamhandler的Python项目详细描述
动态记录器流处理程序
此包包含
AwsSessionManagement-通过假设一个给定的角色来处理AWS会话 它在需要时更新临时凭据
AWS Kinesis Logger StreamHandler-一个可以向AWS Kinesis发送日志的日志流处理程序
用法：
def get_kinesis_client(aws_access_key_id, aws_secret_access_key, aws_session_token):
logger.info("creating/updating kinesis client ...")
kinesis = boto3.client('kinesis', region_name=get_region(),
aws_access_key_id = aws_access_key_id,
aws_secret_access_key = aws_secret_access_key,
aws_session_token = aws_session_token)
logger.info("returning new kinesis client")
return kinesis
logger = logging.getLogger("my-package")
logger.setLevel(logging.INFO)
kinesisAwsSessionManagement = AwsSessionManagement(role_arn='roleArnValue',
external_id='externalIdValue',
func=get_kinesis_client,
role_session_name="KinesisSession")
kinesis_stream_handler = KinesisDataStreamHandler(kinesis_stream_name, 'subsystem_value', 'component_value', 'action_value', 'project_name', 'env', 'version', kinesisAwsSessionManagement)
kinesis_stream_handler.setLevel(logLevel)
logger.addHandler(kinesis_stream_handler)
现在，每个日志调用都将使用给定的“kinesis_stream_name”将日志同时发送到控制台和kinesis数据流
- 项目
标签：
欢迎加入QQ群-->： 979659372
