FluxPipe

Experimental flux pipeline for embedded or external datasources

Instructions

Download a binary release or build from source

📦 Download Binary

curl -fsSL github.com/lmangani/fluxpipe/releases/latest/download/fluxpipe -O && chmod +x fluxpipe

📖 Build

go build -o fluxpipe -ldflags="-s -w" fluxpipe.go

🐛 Test

GEN

echo 'import g "generate" g.from(start: 2022-04-01T00:00:00Z, stop: 2022-04-01T00:03:00Z, count: 5, fn: (n) => 1)' | ./fluxpipe

#datatype,string,long,dateTime:RFC3339,long
#group,false,false,false,false
#default,_result,,,
,result,table,_time,_value
,,0,2022-04-01T00:00:00Z,1
,,0,2022-04-01T00:00:36Z,1
,,0,2022-04-01T00:01:12Z,1
,,0,2022-04-01T00:01:48Z,1
,,0,2022-04-01T00:02:24Z,1

CSV

cat scripts/csv.flux | ./fluxpipe

SQL

cat scripts/sql.flux | ./fluxpipe

Status

  • stdin pipeline
  • http/s api
  • output templates
  • shared dict

GitHub

View Github