Database Services

In FastIoT Framework there are several database helper functions for connecting a database. But to reduce the FastIoT framework size, those libraries must be additionally installed.

• For MongoDB: you can use fastiot.db.mongodb_helper_fn.get_mongodb_client_from_env() to create a mongodb client.

After setting all relevant env variables (s. fastiot.db.mongodb_helper_fn.get_mongodb_client_from_env()), you can access mongodb client through following code:

mongodb_client = get_mongodb_client_from_env()
mongodb_client.insertOne()

With mongodb_client you can access all functions in mongodb api. Details s. https://pymongo.readthedocs.io/en/stable/index.html

• For MariaDB: you can use fastiot.db.mariadb_helper_fn.get_mariadb_client_from_env() to create a mariadb client.

mariadb_client = get_mariadb_client_from_env()

mariadb_client includes all functions from mariadb api. Details s. https://mariadb-corporation.github.io/mariadb-connector-python/usage.html

• For InfluxDB: you can use fastiot.db.influxdb_helper_fn.get_async_influxdb_client_from_env() to create a influxdb client.

influxdb_client = await get_async_influxdb_client_from_env()

This function will return a async influxdb_client. Details s. https://influxdb-client.readthedocs.io/en/stable/usage.html#how-to-use-asyncio

• For TimeScaleDB: you can use fastiot.db.time_scale_helper_fn.get_timescaledb_client_from_env() to create a time scale connection.

time_scale_db_client = get_timescaledb_client_from_env()

With this time_scale_db_client you can access all functions in psycopg2 api. Before working with psycopg2, the libpq-dev must be manuelly installed in your OS to install psycopg2 ! Details s. https://www.psycopg.org/docs/