Uploaded image for project: 'Apache NiFi'
  1. Apache NiFi
  2. NIFI-5226

Implement a Record API based PutInfluxDB processor

    XMLWordPrintableJSON

    Details

    • Type: Improvement
    • Status: Resolved
    • Priority: Major
    • Resolution: Won't Do
    • Affects Version/s: None
    • Fix Version/s: None
    • Component/s: Extensions

      Description

      Implement a new processor that uses the Record API to put data into InfluxDB.

      PutInfluxDBRecord features:

      • Input can be any built-in or custom implemented NiFi RecordReader (json, avro, csv, InfluxLineProtocolReader...)
      • Configurable mapping between NiFi Records and InfluxDB measurement, field and tags
      • Configurable timestamp precision
      • Reusable connection settings (InfluxDB url, password) for more processors via InfluxDBService controller
      • Advanced InfluxDB client settings
        • Gzip compression
        • Batching, jitter, flush settings

      InfluxDBService features:

      • InfluxDBService allows sharing connection configuration among more NiFi processors.
      • SSL support

      InfluxLineProtocolReader features

      • InfluxLineProtocolReader parses the InfluxDB Line Protocol into NiFi Record. This allows processing, filtering and partitioning data in NiFi obtained from Telegraf agents, IoT devices, InfluxDB subscriptions and other InfluxDB Line protocol devices.

        Attachments

          Activity

            People

            • Assignee:
              Unassigned
              Reporter:
              bonitoo-engineers Bonitoo4Influxdata Engineering
            • Votes:
              1 Vote for this issue
              Watchers:
              6 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved:

                Time Tracking

                Estimated:
                Original Estimate - Not Specified
                Not Specified
                Remaining:
                Remaining Estimate - 0h
                0h
                Logged:
                Time Spent - 2h
                2h