InfluxDB

Connection

class InfluxDBConnection(app, id=None, config=None)[source]

Bases: Connection

Description: InfluxDBConnection serves to connect BSPump application with an InfluxDB database. The InfluxDB server is accessed via URL, and the database is specified using the db parameter in the configuration.

app = bspump.BSPumpApplication()
svc = app.get_service("bspump.PumpService")
svc.add_connection(
        bspump.influxdb.InfluxDBConnection(app, "InfluxConnection1")
)

**Config Default**

url : http://localhost:8086/

db : mydb

output_queue_max_size : 10

output_bucket_max_size : 1000 * 1000

timout : 30

retry_enabled : False

response_codes_to_retry : 404, 502, 503, 504

InfluxDBConnection.__init__()[source]

Description:

Parameters

appApplication: Name of the Application.

id : ID, default = None

configJSON, default = None: Configuration file with additional information.

Sink

class InfluxDBSink(app, pipeline, connection, id=None, config=None)[source]

Bases: Sink

Description: InfluxDBSink is a sink processor, that stores the event into an InfluxDB database specified in the InfluxDBConnection object.

class SamplePipeline(bspump.Pipeline):

        def __init__(self, app, pipeline_id):
                super().__init__(app, pipeline_id)
                self.build(
                        bspump.socket.TCPStreamSource(app, self, config={'port': 7000}),
                        bspump.influxdb.InfluxDBSink(app, self, "InfluxConnection1")
                )

InfluxDBSink.__init__()[source]

Description:

Parameters

app :

pipeline :

connection :

id : ID, default = None

config : str,JSON, default = None

InfluxDBSink.process(context, event)[source]

Description:

Parameters

context :

eventany data type: Information with timestamp.