RabbitMQ River->Bulk API:Delete or DeleteByQuery?


(Dlemphers) #1

Hi folks,

I'm using the RabbitMQ River to bulk index some feed data, but I can't seem to work out how to do a deletebyquery first, or an upsert like in mongodb. The main issue is I don't have an id for each record, but three very strong fields that make a good update key for our model. Is there a preferred way of approaching bulk upserts in ES?

Thx,

Dave.


(Dlemphers) #2

Had a quick look at the code today, and found the answer:

package org.elasticsearch.client.action.bulk only implements support for DeleteRequest, not DeleteByQuery.

Oh well. :frowning:


(system) #3