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