Use the Python client elasticsearch.
from elasticsearch import Elasticsearch
es_client = Elasticsearch() # local
| import boto3 # AWS SDK for Python | |
| import os | |
| from base64 import b64decode | |
| # Retrieve environment variables | |
| encrypted_environment_variable_a = os.environ['a'] | |
| encrypted_environment_variable_b = os.environ['b'] | |
| # KMS Client |
| module HTTP; | |
| # Add additional HTTP Headers | |
| redef record Info += { | |
| #Origin "Origin" | |
| origin: string &log &optional; | |
| }; | |
| event http_header(c: connection, is_orig: bool, name: string, value: string) &priority=5 |