def put_events()

in 04_EdgeApplication/report/lambda_ingest_logs_cloudwatch.py [0:0]

• 14 lines of code
• 2 McCabe index (conditional complexity)

def put_events(log_stream_name, data):
    resp = logs_client.describe_log_streams(
        logGroupName='/wind-turbine-farm',
        logStreamNamePrefix=log_stream_name
    )
    next_token=resp['logStreams'][0].get('uploadSequenceToken')
    params = dict(
        logGroupName='/wind-turbine-farm',
        logStreamName=log_stream_name,
        logEvents=data
    )
    if next_token is not None:
        params['sequenceToken'] = next_token
    logs_client.put_log_events(**params)