run_es.py

from elasticsearch import Elasticsearch, RequestsHttpConnection
from requests_aws4auth import AWS4Auth
import os
def init_es():
    host = os.environ['ES_HOST']
    if os.environ['ES_USE_AWS'] is "1":
        awsauth = AWS4Auth(os.environ['AWS_ES_ID'], os.environ['AWS_ES_SECRET'], os.environ['AWS_ES_REGION'], 'es')
    es = Elasticsearch(
        hosts=[{'host': host, 'port': 443}],
        http_auth=awsauth,
        use_ssl=True,
        verify_certs=True,
        connection_class=RequestsHttpConnection
    )
    return es
def index_res(es, status_id, status_data):
    print("Now saving the result to ElasticSearch "  + str(status_id))
    es.index(index=os.environ['INDEX_NAME'], doc_type='fb_post', id=status_id, body=status_data)