Connect to elasticsearch using python snippet

[garvitbhatia]

I am trying to connect to the local elasticsearch instance and perform basic CRUD operation. Following is the code I am using:

from elasticsearch import Elasticsearch
def writeToElastic():
    es = Elasticsearch([{'host':'localhost','port':9200}])
    doc = {"jobName":"CustomPiepline","executionStatus":"running"}
    res = es.index(index='custom_index',doc_type='status',id=1,body=doc)

And following are the Python Processor's configurations:

The pipeline runs without error, but no index is created in the elasticsearch. Any help would be appreciated