Hi,
I am afraid the easiest solution here is to not use rivers but instead
do the loading yourself - using a dedicated python process to consume
the twitter stream, enriching the data and loading it into
elasticsearch using the stream_bulk helper in the official python
client (0).
0 -
Hi,
I use the twitter river who use bulk indexing.
I have a Python script who analyse tweets and return some data.
So i want to analyse each tweet and add two fields to the river with the
returned data.
Maybe i can build a second sheme with id and treatment status in order to
run the script
