到influxDB的线路协议语句的nifi executeScript

import org.apache.commons.io.IOUtils
import java.nio.charset.StandardCharsets

def flowFile = session.get()
if (flowFile == null) {
    return
}

def influxDBUrl = 'http://your-influxdb-url'
def database = 'your-database'
def measurement = 'your-measurement'
def lineProtocol = 'your-line-protocol-statement'

def command = "curl -i -XPOST '${influxDBUrl}/write?db=${database}' --data-binary '${lineProtocol}'"
def process = command.execute()
def output = process.inputStream.text

if (process.exitValue() == 0) {
    flowFile = session.putAttribute(flowFile, 'influxdb.status', 'success')
} else {
    flowFile = session.putAttribute(flowFile, 'influxdb.status', 'failure')
    flowFile = session.putAttribute(flowFile, 'influxdb.error', output)
}

session.transfer(flowFile, REL_SUCCESS)