Skip to content

Add a plugin for InfluxDB #2

@anna-geller

Description

@anna-geller

Feature description

Following the plugin documentation you will have to :

  • Use this plugin template
  • Use the java driver
  • Create multiple tasks using this drivers
    • Write a measure: io.kestra.plugin.influxdb.Write: The source will be a a multiline string in wire format. Also add an alternative source (instead of string) that is an ion file creating DataPoint in bulk.
    • Query the database using Flux : io.kestra.plugin.influxdb.FluxQuery:
      • User will have a fetchType to decide the output type if it's ion internal storage or inside the execution
      • The data should be casted in proper java type (Double, etc ...)
    • Query the database using InfluxQL : io.kestra.plugin.influxdb.InfluxQLQuery: same condition as the flux query
    • Trigger : io.kestra.plugin.influxdb.FluxTrigger that starts an execution as soon as the query returns some result.
  • Each task should have integration test (sanitychecks) running against a docker server already started

Metadata

Metadata

Labels

area/pluginPlugin-related issue or feature requestgood first issueGreat issue for new contributors

Projects

No projects

Milestone

No milestone

Relationships

None yet

Development

No branches or pull requests

Issue actions