- 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 pyarrowdependency
- write_batching_by_bytes_count.py - How to use RxPY to prepare batches by maximum bytes count.
- query.py - How to query data into
FluxTables,StreamandCSV - query_from_file.py - How to use a Flux query defined in a separate file
- query_response_to_json.py - How to serialize Query response to JSON
- query_with_profilers.py - How to process profilers output by callback
- buckets_management.py - How to create, list and delete Buckets
- monitoring_and_alerting.py - How to create the Check with Slack notification.
- task_example.py - How to create a Task by API
- templates_management.py - How to use Templates and Stack API
- 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
- influxdb_18_example.py - How to connect to InfluxDB 1.8
- nanosecond_precision.py - How to use nanoseconds precision
- connection_check.py - How to check connection configuration
- asynchronous.py - How to use Asyncio with InfluxDB client
- asynchronous_management.py - How to use asynchronous Management API
- asynchronous_batching.py - How to use RxPY to prepare batches
- asynchronous_retry.py - How to use aiohttp-retry to configure retries