How to segericate the twitter json file based on #tag and store into different location Using NiFi?

iyappan — Mon, 20 Jun 2016 17:45:08 GMT

I can able to receive the twitter files as Json format from my twitter account but
i need to filter these files based on #tags (Ex, #fourseasondallas)
stored in a separate directory

Thanks

Re: How to segericate the twitter json file based on #tag and store into different location Using NiFi?

bbende — Mon, 20 Jun 2016 22:36:04 GMT

Looks like the Twitter API puts hash tags into the following JSON:

"entities": { "hashtags":[], "urls":[], "user_mentions":[] }

You could use EvaluteJsonPath to extract the value of the hashtags into FlowFile attributes, and then use RouteOnAttribute to route the ones matching your tag to a PutFile processor.

This blog shows an example of extracting values from the Twitter JSON and making routing decisions:

https://blogs.apache.org/nifi/entry/indexing_tweets_with_nifi_and

question How to segericate the twitter json file based on #tag and store into different location Using NiFi? in Archives of Support Questions (Read Only)

How to segericate the twitter json file based on #tag and store into different location Using NiFi?

Re: How to segericate the twitter json file based on #tag and store into different location Using NiFi?