| 12345678910111213141516171819202122232425262728293031 |
- import boto3
- import re,json,base64,gzip
- import requests
- from requests_aws4auth import AWS4Auth
- region = 'cn-northwest-1'
- service = 'es'
- credentials = boto3.Session().get_credentials()
- awsauth = AWS4Auth(credentials.access_key,credentials.secret_key,region,service,session_token=credentials.token)
- host = 'https://search-es-test-rssutkotldfmnca64hpfbi5jya.cn-northwest-1.es.amazonaws.com.cn'
- index = 'lambda-cw'
- type_a = 'lambda-type'
- url = host + '/' + index + '/' + type_a
- headers = {"Content-Type":"application/json"}
- def lambda_handler(event, context):
- de_content = base64.b64decode(event['awslogs']['data'])
- ret = json.loads(gzip.decompress(de_content).decode('utf8'))
- # log_msg = ret['logEvents'][0]['message']
- # tup_log = log_msg.split(' ', -1)
- # tup_log = json.loads(tup_log)
- # print(type(tup_log))
- r = requests.post(url,auth=awsauth,json=ret,headers=headers)
- print(r)
-
|
