docs: Querying

Author: bednar

MIGRATION_GUIDE.md

@@ -23,6 +23,7 @@ Please take a moment to review the following client docs:
   - [Dictionary-style object](#writing-dictionary-style-object)
   - [Structured data](#writing-structured-data)
   - [Pandas DataFrame](#writing-pandas-dataframe)
+- [Querying](#querying)
 
 ## Initializing Client
 
@@ -285,9 +286,36 @@ with InfluxDBClient(url='http://localhost:8086', token='my-token', org='my-org')
 **influxdb-python**
 
 ```python
+from influxdb import InfluxDBClient
+
+client = InfluxDBClient(host='127.0.0.1', port=8086, username='root', password='root', database='dbname')
+
+points = client.query('SELECT * from cpu').get_points()
+for point in points:
+    print(point)
 ```
 
 **influxdb-client-python**
 
 ```python
+from influxdb_client import InfluxDBClient
+
+with InfluxDBClient(url='http://localhost:8086', token='my-token', org='my-org', debug=True) as client:
+    query = '''from(bucket: "my-bucket")
+  |> range(start: -10000d)
+  |> filter(fn: (r) => r["_measurement"] == "cpu")
+  |> pivot(rowKey:["_time"], columnKey: ["_field"], valueColumn: "_value")
+'''
+
+    tables = client.query_api().query(query)
+    for record in [record for table in tables for record in table.records]:
+        print(record.values)
+```
+
+If you would like to omit boilerplate columns such as `_result`, `_table`, `_start`, ... you can filter the record values by following expression:
+
+```python
+print({k: v for k, v in record.values.items() if k not in ['result', 'table', '_start', '_stop', '_measurement']})
 ```
+
+For more info see [Flux Response Format](https://github.com/influxdata/flux/blob/master/docs/SPEC.md#response-format).

examples/buckets_management.py

@@ -1,24 +1,42 @@
-from influxdb_client import InfluxDBClient
-from influxdb_client.client.write_api import SYNCHRONOUS
+"""
+How to How to create, list and delete Buckets.
+"""
 
-with InfluxDBClient(url='http://localhost:8086', token='my-token', org='my-org') as client:
-    write_api = client.write_api(write_options=SYNCHRONOUS)
+from influxdb_client import InfluxDBClient, BucketRetentionRules
 
-    record = [
-        {
-            "measurement": "cpu_load_short",
-            "tags": {
-                "host": "server01",
-                "region": "us-west"
-            },
-            "time": "2009-11-10T23:00:00Z",
-            "fields": {
-                "Float_value": 0.64,
-                "Int_value": 3,
-                "String_value": "Text",
-                "Bool_value": True
-            }
-        }
-    ]
+"""
+Define credentials
+"""
+url = "http://localhost:8086"
+token = "my-token"
+org = "my-org"
+
+with InfluxDBClient(url=url, token=token) as client:
+    buckets_api = client.buckets_api()
+
+    """
+    Create Bucket with retention policy set to 3600 seconds and name "bucket-by-python"
+    """
+    print(f"------- Create -------\n")
+    retention_rules = BucketRetentionRules(type="expire", every_seconds=3600)
+    created_bucket = buckets_api.create_bucket(bucket_name="bucket-by-python",
+                                               retention_rules=retention_rules,
+                                               org=org)
+    print(created_bucket)
+
+    """
+    List all Buckets
+    """
+    print(f"\n------- List -------\n")
+    buckets = buckets_api.find_buckets().buckets
+    print("\n".join([f" ---\n ID: {bucket.id}\n Name: {bucket.name}\n Retention: {bucket.retention_rules}"
+                     for bucket in buckets]))
+    print("---")
+
+    """
+    Delete previously created bucket
+    """
+    print(f"------- Delete -------\n")
+    buckets_api.delete_bucket(created_bucket)
+    print(f" successfully deleted bucket: {created_bucket.name}")
 
-    write_api.write(bucket='my-bucket', record=record)