Examples

Writes

import_data_set.py - How to import CSV file
import_data_set_multiprocessing.py - How to large CSV file by Python Multiprocessing
ingest_dataframe_default_tags.py - How to ingest DataFrame with default tags
ingest_large_dataframe.py - How to ingest large DataFrame
iot_sensor.py - How to write sensor data every minute by RxPY
import_data_set_sync_batching.py - How to use RxPY to prepare batches for synchronous write into InfluxDB
write_api_callbacks.py - How to handle batch events
write_structured_data.py - How to write structured data - NamedTuple, Data Classes - (requires Python v3.8+)
logging_handler.py - How to set up a python native logging handler that writes to InfluxDB
import_parquet.py - How to import Apache Parquet data files, the example requires:
- manually download NYC TLC Trip Record Data
- install Apache Arrow pip install pyarrow dependency
write_batching_by_bytes_count.py - How to use RxPY to prepare batches by maximum bytes count.
http_error_handling.py - How to leverage HttpHeader information when errors are returned on write.

⚠️ The following examples are related to InfluxDB Cloud and not available on a local InfluxDB OSS instance.

influx_cloud.py - How to connect to InfluxDB 2 Cloud
invokable_scripts.py - How to use Invokable scripts Cloud API to create custom endpoints that query data
bucket_schemas.py - How to manage explicit bucket schemas to enforce column names, tags, fields, and data types for your data