How does we can implement ingest pipeline in runtime

Hi Team,

I created a ingest pipeline like below.

PUT _ingest/pipeline/test2
{
"description": "Test the pipe line",
"processors": [
{
"remove": {
"field": "account_number"
},
"set": {
"field": "_source.fullname",
"value": "{{_source.firstname}} {{_source.lastname}}"
},
"convert": {
"field": "age",
"type": "string"
}
}
]
}

It is working at the time of reindexing.

POST _reindex
{
"source": {
"index": "sample-1"
},
"dest": {
"index": "accountsbanks"
, "pipeline": "test2"
}
}

But when I add the documents after reindexing it's not working.

POST _bulk
{ "index" : {"_index" : "accountsbanks", "_id" : "1003" }}
{ "account_number" : 13, "firstname" : "Nanette", "address" : "789 Madison Street", "balance" : 46812, "gender" : "F", "city" : "Nogal", "employer" : "Quility", "state" : "VA", "transactions" : 4, "age" : 28, "email" : "nanettebates@quility.com", "lastname" : "Bates"}

Could you please help me how does I can apply when I add this extra documents after applying pipeline

Try with:

POST _bulk?pipeline=test2

It worked. Thanks

This topic was automatically closed 28 days after the last reply. New replies are no longer allowed.