Name		Name	Last commit message	Last commit date
parent directory ..
README.md		README.md
asynchronous.py		asynchronous.py
asynchronous_batching.py		asynchronous_batching.py
asynchronous_management.py		asynchronous_management.py
asynchronous_retry.py		asynchronous_retry.py
bucket_schemas.py		bucket_schemas.py
buckets_management.py		buckets_management.py
connection_check.py		connection_check.py
example.py		example.py
http_error_handling.py		http_error_handling.py
import_data_set.py		import_data_set.py
import_data_set_multiprocessing.py		import_data_set_multiprocessing.py
import_data_set_sync_batching.py		import_data_set_sync_batching.py
import_parquet.py		import_parquet.py
influx_cloud.py		influx_cloud.py
influxdb_18_example.py		influxdb_18_example.py
ingest_dataframe_default_tags.py		ingest_dataframe_default_tags.py
ingest_large_dataframe.py		ingest_large_dataframe.py
invokable_scripts.py		invokable_scripts.py
iot_sensor.py		iot_sensor.py
logging_handler.py		logging_handler.py
monitoring_and_alerting.py		monitoring_and_alerting.py
nanosecond_precision.py		nanosecond_precision.py
query.flux		query.flux
query.py		query.py
query_from_file.py		query_from_file.py
query_response_to_json.py		query_response_to_json.py
query_with_profilers.py		query_with_profilers.py
rx_playground.py		rx_playground.py
task_example.py		task_example.py
templates_management.py		templates_management.py
vix-daily.csv		vix-daily.csv
write_api_callbacks.py		write_api_callbacks.py
write_batching_by_bytes_count.py		write_batching_by_bytes_count.py
write_structured_data.py		write_structured_data.py

README.md

Examples

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