Skip to content
This repository has been archived by the owner on Dec 26, 2024. It is now read-only.

Commit

Permalink
#6: Added demo 1 description
Browse files Browse the repository at this point in the history
  • Loading branch information
bednar committed Feb 14, 2019
1 parent 1f48136 commit d42b03a
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions README.md
Original file line number Diff line number Diff line change
Expand Up @@ -165,7 +165,7 @@ Allows sharing connection configuration among more NiFi processors. Also support

### Store complex JSON structure to InfluxDB

As NiFi user We want to put data (complex json structure) to InfluxDB in order to work with time series.
As NiFi user we want to put data (complex json structure) to InfluxDB in order to work with time series.

The demo reads data from Twitter in complex JSON format based on supplied keywords and writes them into InfluxDB.
Data from Twitter are streamed into NiFi using built-in `org.apache.nifi.processors.twitter.GetTwitter` processor.
Expand Down Expand Up @@ -233,8 +233,8 @@ The mapping between NiFi Record fields and JSON is configured in dynamic propert
Next we set mapping between NiFi Record and InfluxDB measurement/tags/field/timestamp).

- Measurement - `tweets`
- Fields - record field values: `tweet_id,retweet_count,followers_count,friends_count,favourites_count,screen_name,text`
- Tags - record field values: `lang,keyword,user_verified`
- Fields - record field values: `tweet_id`, `retweet_count`, `followers_count`, `friends_count`, `favourites_count`, `screen_name`, `text`
- Tags - record field values: `lang,keyword`, `user_verified`
- Timestamp - record field value: `timestamp`

#### Result
Expand Down

0 comments on commit d42b03a

Please sign in to comment.