writeRecords

abstract suspend fun writeRecords(records: Iterable<String>, precision: WritePrecision, bucket: String? = null, org: String? = null)(source)
abstract suspend fun writeRecords(records: Flow<String>, precision: WritePrecision, bucket: String? = null, org: String? = null)(source)

Write Line Protocol records into InfluxDB.

If any exception occurs during write, this exception is rethrown from this method.

Parameters

records

specified in LineProtocol. The records are considered as one batch unit.

precision

precision for the unix timestamps within the body line-protocol

bucket

specifies the destination bucket for writes. The com.influxdb.client.InfluxDBClientOptions.getBucket will be used as the destination bucket if the bucket is not specified.

org

specifies the destination organization for writes. The com.influxdb.client.InfluxDBClientOptions.getOrg will be used as the destination organization if the org is not specified.


abstract suspend fun writeRecords(records: Flow<String>, parameters: WriteParameters)(source)

Write Line Protocol records into InfluxDB.

If any exception occurs during write, this exception is rethrown from this method.

Parameters

records

specified in LineProtocol. The records are considered as one batch unit.

parameters

specify InfluxDB Write endpoint parameters