AshCusack
diff --git a/‎CHANGELOG.md
Lines changed: 3 additions & 0 deletions b/‎CHANGELOG.md
Lines changed: 3 additions & 0 deletions
diff --git a/‎examples/README.md
Lines changed: 8 additions & 3 deletions b/‎examples/README.md
Lines changed: 8 additions & 3 deletions
diff --git a/‎examples/bucket_schemas.py
Lines changed: 95 additions & 0 deletions b/‎examples/bucket_schemas.py
Lines changed: 95 additions & 0 deletions
diff --git a/‎examples/invokable_scripts.py
Lines changed: 3 additions & 0 deletions b/‎examples/invokable_scripts.py
Lines changed: 3 additions & 0 deletions
diff --git a/‎influxdb_client/__init__.py
Lines changed: 8 additions & 0 deletions b/‎influxdb_client/__init__.py
Lines changed: 8 additions & 0 deletions
diff --git a/‎influxdb_client/client/__init__.py
Lines changed: 1 addition & 0 deletions b/‎influxdb_client/client/__init__.py
Lines changed: 1 addition & 0 deletions
diff --git a/‎influxdb_client/client/_base.py
Lines changed: 0 additions & 7 deletions b/‎influxdb_client/client/_base.py
Lines changed: 0 additions & 7 deletions
diff --git a/‎influxdb_client/client/bucket_api.py
Lines changed: 1 addition & 1 deletion b/‎influxdb_client/client/bucket_api.py
Lines changed: 1 addition & 1 deletion
diff --git a/‎influxdb_client/client/influxdb_client.py
Lines changed: 11 additions & 1 deletion b/‎influxdb_client/client/influxdb_client.py
Lines changed: 11 additions & 1 deletion
diff --git a/‎influxdb_client/client/influxdb_client_async.py
Lines changed: 11 additions & 1 deletion b/‎influxdb_client/client/influxdb_client_async.py
Lines changed: 11 additions & 1 deletion
@@ -1,5 +1,8 @@
 ## 1.35.0 [unreleased]
 
+### Features
+1. [#528](https://github.com/influxdata/influxdb-client-python/pull/528): Add `BucketSchemasService` to manage explicit bucket schemas to enforce column names, tags, fields, and data types for your data
+
 ### Bug Fixes
 1. [#526](https://github.com/influxdata/influxdb-client-python/pull/526): Creating client instance from static configuration
 1. [#531](https://github.com/influxdata/influxdb-client-python/pull/531): HTTP request return type for Management API [async/await]
 
@@ -22,18 +22,23 @@
 - [query_response_to_json.py](query_response_to_json.py) - How to serialize Query response to JSON
 - [query_with_profilers.py](query_with_profilers.py) - How to process profilers output by callback
 
-
 ## Management API
 - [buckets_management.py](buckets_management.py) - How to create, list and delete Buckets
 - [monitoring_and_alerting.py](monitoring_and_alerting.py) - How to create the Check with Slack notification.
 - [task_example.py](task_example.py) - How to create a Task by API
 - [templates_management.py](templates_management.py) - How to use Templates and Stack API
 
-## Others
+## InfluxDB Cloud
+
+:warning: The following examples are related to [InfluxDB Cloud](https://docs.influxdata.com/influxdb/cloud/) and not available on a local InfluxDB OSS instance.
+
 - [influx_cloud.py](influx_cloud.py) - How to connect to InfluxDB 2 Cloud
+- [invokable_scripts.py](invokable_scripts.py) - How to use Invokable scripts Cloud API to create custom endpoints that query data
+- [bucket_schemas.py](bucket_schemas.py) - How to manage explicit bucket schemas to enforce column names, tags, fields, and data types for your data
+
+## Others
 - [influxdb_18_example.py](influxdb_18_example.py) - How to connect to InfluxDB 1.8
 - [nanosecond_precision.py](nanosecond_precision.py) - How to use nanoseconds precision
-- [invokable_scripts.py](invokable_scripts.py) - How to use Invokable scripts Cloud API to create custom endpoints that query data
 - [connection_check.py](connection_check.py) - How to check connection configuration
 
 ## Asynchronous
 
@@ -0,0 +1,95 @@
+"""
+This example is related to `InfluxDB Cloud <https://docs.influxdata.com/influxdb/cloud/>`_ and not available
+on a local InfluxDB OSS instance.
+
+How to manage explicit bucket schemas to enforce column names, tags, fields, and data types for your data.
+"""
+import datetime
+
+from influxdb_client import InfluxDBClient, BucketSchemasService, PostBucketRequest, SchemaType, \
+    MeasurementSchemaCreateRequest, MeasurementSchemaColumn, ColumnSemanticType, ColumnDataType, \
+    MeasurementSchemaUpdateRequest
+
+"""
+Define credentials
+"""
+influx_cloud_url = 'https://us-west-2-1.aws.cloud2.influxdata.com'
+influx_cloud_token = '...'
+org_name = '...'
+
+with InfluxDBClient(url=influx_cloud_url, token=influx_cloud_token, org=org_name, debug=False) as client:
+    uniqueId = str(datetime.datetime.now())
+    org_id = client.organizations_api().find_organizations(org=org_name)[0].id
+    bucket_schemas_api = BucketSchemasService(api_client=client.api_client)
+
+    """
+    Create a bucket with the schema_type flag set to explicit
+    """
+    print("------- Create Bucket -------\n")
+    created_bucket = client \
+        .buckets_api() \
+        .create_bucket(bucket=PostBucketRequest(name=f"my_schema_bucket_{uniqueId}",
+                                                org_id=org_id,
+                                                retention_rules=[],
+                                                schema_type=SchemaType.EXPLICIT))
+    print(created_bucket)
+
+    """
+    Sets the schema for a measurement: Usage CPU
+
+    [
+        {"name": "time", "type": "timestamp"},
+        {"name": "service", "type": "tag"},
+        {"name": "host", "type": "tag"},
+        {"name": "usage_user", "type": "field", "dataType": "float"},
+        {"name": "usage_system", "type": "field", "dataType": "float"}
+    ]
+    """
+    print("------- Create Schema -------\n")
+    columns = [
+        MeasurementSchemaColumn(name="time",
+                                type=ColumnSemanticType.TIMESTAMP),
+        MeasurementSchemaColumn(name="service",
+                                type=ColumnSemanticType.TAG),
+        MeasurementSchemaColumn(name="host",
+                                type=ColumnSemanticType.TAG),
+        MeasurementSchemaColumn(name="usage_user",
+                                type=ColumnSemanticType.FIELD,
+                                data_type=ColumnDataType.FLOAT),
+        MeasurementSchemaColumn(name="usage_system",
+                                type=ColumnSemanticType.FIELD,
+                                data_type=ColumnDataType.FLOAT)
+    ]
+    create_request = MeasurementSchemaCreateRequest(name="usage_cpu", columns=columns)
+    created_schema = bucket_schemas_api.create_measurement_schema(bucket_id=created_bucket.id,
+                                                                  org_id=org_id,
+                                                                  measurement_schema_create_request=create_request)
+    print(created_bucket)
+
+    """
+    Lists the Schemas
+    """
+    print("\n------- Lists the Schemas -------\n")
+    measurement_schemas = bucket_schemas_api.get_measurement_schemas(bucket_id=created_bucket.id).measurement_schemas
+    print("\n".join([f"---\n ID: {ms.id}\n Name: {ms.name}\n Columns: {ms.columns}" for ms in measurement_schemas]))
+    print("---")
+
+    """
+    Update a bucket schema
+    """
+    print("------- Update a bucket schema -------\n")
+    columns.append(MeasurementSchemaColumn(name="usage_total",
+                                           type=ColumnSemanticType.FIELD,
+                                           data_type=ColumnDataType.FLOAT))
+    update_request = MeasurementSchemaUpdateRequest(columns=columns)
+    updated_schema = bucket_schemas_api.update_measurement_schema(bucket_id=created_bucket.id,
+                                                                  measurement_id=created_schema.id,
+                                                                  measurement_schema_update_request=update_request)
+    print(updated_schema)
+
+    """
+    Delete previously created bucket
+    """
+    print("------- Delete Bucket -------\n")
+    client.buckets_api().delete_bucket(created_bucket)
+    print(f" successfully deleted bucket: {created_bucket.name}")
@@ -1,4 +1,7 @@
 """
+This example is related to `InfluxDB Cloud <https://docs.influxdata.com/influxdb/cloud/>`_ and not available
+on a local InfluxDB OSS instance.
+
 How to use Invokable scripts Cloud API to create custom endpoints that query data
 """
 import datetime
 
@@ -17,6 +17,7 @@
 # import apis into sdk package
 from influxdb_client.service.authorizations_service import AuthorizationsService
 from influxdb_client.service.backup_service import BackupService
+from influxdb_client.service.bucket_schemas_service import BucketSchemasService
 from influxdb_client.service.buckets_service import BucketsService
 from influxdb_client.service.cells_service import CellsService
 from influxdb_client.service.checks_service import ChecksService
@@ -100,6 +101,8 @@
 from influxdb_client.domain.check_status_level import CheckStatusLevel
 from influxdb_client.domain.check_view_properties import CheckViewProperties
 from influxdb_client.domain.checks import Checks
+from influxdb_client.domain.column_data_type import ColumnDataType
+from influxdb_client.domain.column_semantic_type import ColumnSemanticType
 from influxdb_client.domain.conditional_expression import ConditionalExpression
 from influxdb_client.domain.config import Config
 from influxdb_client.domain.constant_variable_properties import ConstantVariableProperties
@@ -167,6 +170,11 @@
 from influxdb_client.domain.logs import Logs
 from influxdb_client.domain.map_variable_properties import MapVariableProperties
 from influxdb_client.domain.markdown_view_properties import MarkdownViewProperties
+from influxdb_client.domain.measurement_schema import MeasurementSchema
+from influxdb_client.domain.measurement_schema_column import MeasurementSchemaColumn
+from influxdb_client.domain.measurement_schema_create_request import MeasurementSchemaCreateRequest
+from influxdb_client.domain.measurement_schema_list import MeasurementSchemaList
+from influxdb_client.domain.measurement_schema_update_request import MeasurementSchemaUpdateRequest
 from influxdb_client.domain.member_assignment import MemberAssignment
 from influxdb_client.domain.member_expression import MemberExpression
 from influxdb_client.domain.metadata_backup import MetadataBackup
 
@@ -15,6 +15,7 @@
 # import apis into api package
 from influxdb_client.service.authorizations_service import AuthorizationsService
 from influxdb_client.service.backup_service import BackupService
+from influxdb_client.service.bucket_schemas_service import BucketSchemasService
 from influxdb_client.service.buckets_service import BucketsService
 from influxdb_client.service.cells_service import CellsService
 from influxdb_client.service.checks_service import ChecksService
 
@@ -98,13 +98,6 @@ def __init__(self, url, token, debug=None, timeout=10_000, enable_gzip=False, or
         self.profilers = kwargs.get('profilers', None)
         pass
 
-    def _version(self, response) -> str:
-        if response is not None and len(response) >= 3:
-            if 'X-Influxdb-Version' in response[2]:
-                return response[2]['X-Influxdb-Version']
-
-        return "unknown"
-
     @classmethod
     def _from_config_file(cls, config_file: str = "config.ini", debug=None, enable_gzip=False, **kwargs):
         config = configparser.ConfigParser()
 
@@ -22,7 +22,7 @@ def create_bucket(self, bucket=None, bucket_name=None, org_id=None, retention_ru
                       description=None, org=None) -> Bucket:
         """Create a bucket.
 
-        :param Bucket bucket: bucket to create
+        :param Bucket|PostBucketRequest bucket: bucket to create
         :param bucket_name: bucket name
         :param description: bucket description
         :param org_id: org_id
@@ -407,7 +407,17 @@ def version(self) -> str:
 
         response = ping_service.get_ping_with_http_info(_return_http_data_only=False)
 
-        return self._version(response)
+        return ping_service.response_header(response)
+
+    def build(self) -> str:
+        """
+        Return the build type of the connected InfluxDB Server.
+
+        :return: The type of InfluxDB build.
+        """
+        ping_service = PingService(self.api_client)
+
+        return ping_service.build_type()
 
     def ready(self) -> Ready:
         """
 
@@ -251,7 +251,17 @@ async def version(self) -> str:
         ping_service = PingService(self.api_client)
 
         response = await ping_service.get_ping_async(_return_http_data_only=False)
-        return self._version(response)
+        return ping_service.response_header(response)
+
+    async def build(self) -> str:
+        """
+        Return the build type of the connected InfluxDB Server.
+
+        :return: The type of InfluxDB build.
+        """
+        ping_service = PingService(self.api_client)
+
+        return await ping_service.build_type_async()
 
     def query_api(self, query_options: QueryOptions = QueryOptions()) -> QueryApiAsync:
         """