feat: remove org from examples code

CHANGELOG.md

@@ -2,6 +2,9 @@
 
 ## 0.13.0 [unreleased]
 
+### Features
+
+1. [#130](https://github.com/InfluxCommunity/influxdb3-python/pull/130): Remove org parameters from the example code because It is not mandatory in Influxdb3
 
 ## 0.12.0 [2025-03-26] 
 

Examples/basic_ssl_example.py

@@ -70,7 +70,6 @@ def write_and_query_with_explicit_sys_cert(conf):
     print("\nwrite and query with typical linux system cert\n")
     with InfluxDBClient3(token=conf.token,
                          host=conf.host,
-                         org=conf.org,
                          database=conf.database,
                          ssl_ca_cert="/etc/ssl/certs/ca-certificates.crt",
                          verify_ssl=True) as _client:
@@ -90,7 +89,6 @@ def query_with_verify_ssl_off(conf, cert):
     # Switch verify_ssl to True to throw SSL_ERROR_SSL
     with InfluxDBClient3(token=conf.token,
                          host=conf.host,
-                         org=conf.org,
                          database=conf.database,
                          ssl_ca_cert=cert,
                          verify_ssl=False) as _client:

Examples/batching_example.py

@@ -70,7 +70,6 @@ def main() -> None:
     # of 10k ms and gzip compression
     with InfluxDBClient3.InfluxDBClient3(token=conf.token,
                                          host=conf.host,
-                                         org=conf.org,
                                          database=conf.database,
                                          enable_gzip=True,
                                          write_client_options=wco) as _client:

Examples/cloud_dedicated_query.py

@@ -6,7 +6,6 @@
 client = InfluxDBClient3.InfluxDBClient3(
     token=config.token,
     host=config.host,
-    org=config.org,
     database=config.database)
 
 table = client.query(

Examples/cloud_dedicated_write.py

@@ -9,7 +9,6 @@
 client = InfluxDBClient3.InfluxDBClient3(
     token=config.token,
     host=config.host,
-    org=config.org,
     database=config.database,
     write_options=WriteOptions(
         batch_size=500,

Examples/community/custom_url.py

@@ -36,7 +36,6 @@ def retry(self, conf, data: str, exception: InfluxDBError):
 client = InfluxDBClient3(
     token="",
     host="https://eu-central-1-1.aws.cloud2.influxdata.com:442",
-    org="6a841c0c08328fb1",
     database="pokemon-codex", enable_gzip=True, write_client_options=wco, write_port_overwrite=443,
     query_port_overwrite=443)
 

Examples/community/database_transfer.py

@@ -18,7 +18,6 @@ def retry(self, conf, data: str, exception: InfluxDBError):
 
 # InfluxDB connection details
 token = ""
-org = "6a841c0c08328fb1"
 dbfrom = "a"
 dbto = "b"
 url = "eu-central-1-1.aws.cloud2.influxdata.com"
@@ -44,7 +43,6 @@ def retry(self, conf, data: str, exception: InfluxDBError):
 # of 10k ms and gzip compression
 with InfluxDBClient3.InfluxDBClient3(token=token,
                                      host=url,
-                                     org=org,
                                      enable_gzip=True, write_client_options=wco) as _client:
     query = f"SHOW TAG KEYS FROM {measurement}"
     tags = _client.query(query=query, language="influxql", database=dbfrom)

Examples/config.py

@@ -6,7 +6,6 @@ class Config:
     def __init__(self):
         self.host = os.getenv('INFLUXDB_HOST') or 'https://us-east-1-1.aws.cloud2.influxdata.com/'
         self.token = os.getenv('INFLUXDB_TOKEN') or 'my-token'
-        self.org = os.getenv('INFLUXDB_ORG') or 'my-org'
         self.database = os.getenv('INFLUXDB_DATABASE') or 'my-db'
 
     def __str__(self):

Examples/file-import/csv_write.py

@@ -43,15 +43,13 @@ def main() -> None:
     """
        token: access token generated in cloud
        host: ATTN could be another AWS region or even another cloud provider
-       org: organization associated with account and database
        database: should have retention policy 'forever' to handle older sample data timestamps
        write_client_options: see above
        debug: allows low-level inspection of communications and context-manager termination
     """
     with InfluxDBClient3.InfluxDBClient3(
             token="INSERT_TOKEN",
             host="https://us-east-1-1.aws.cloud2.influxdata.com/",
-            org="INSERT_ORG",
             database="example_data_forever",
             write_client_options=wco,
             debug=True) as client:

Examples/file-import/feather_write.py

@@ -33,7 +33,6 @@ def retry(self, conf, data: str, exception: InfluxDBError):
 with InfluxDBClient3.InfluxDBClient3(
         token="INSERT_TOKEN",
         host="eu-central-1-1.aws.cloud2.influxdata.com",
-        org="6a841c0c08328fb1",
         database="python", write_client_options=wco) as client:
     client.write_file(
         file='./out.feather',

Examples/file-import/json_write.py

@@ -42,15 +42,13 @@ def main() -> None:
     """
        token: access token generated in cloud
        host: ATTN could be another AWS region or even another cloud provider
-       org: organization associated with account and database
        database: should have retention policy 'forever' to handle older sample data timestamps
        write_client_options: see above
        debug: allows low-level inspection of communications and context-manager termination
     """
     with InfluxDBClient3.InfluxDBClient3(
             token="INSERT_TOKEN",
             host="https://us-east-1-1.aws.cloud2.influxdata.com/",
-            org="INSERT_ORG",
             database="example_data_forever",
             write_client_options=wco,
             debug=True) as client:

Examples/file-import/orc_write.py

@@ -33,7 +33,6 @@ def retry(self, conf, data: str, exception: InfluxDBError):
 with InfluxDBClient3.InfluxDBClient3(
         token="INSERT_TOKEN",
         host="eu-central-1-1.aws.cloud2.influxdata.com",
-        org="6a841c0c08328fb1",
         database="python") as client:
     client.write_file(
         file='./out.orc',

Examples/file-import/parquet_write.py

@@ -33,7 +33,6 @@ def retry(self, conf, data: str, exception: InfluxDBError):
 with InfluxDBClient3.InfluxDBClient3(
         token="INSERT_TOKEN",
         host="eu-central-1-1.aws.cloud2.influxdata.com",
-        org="6a841c0c08328fb1",
         database="python",
         write_client_options=wco) as client:
     client.write_file(

Examples/file-import/write_file_parse_options.py

@@ -33,7 +33,6 @@ def retry(self, conf, data: str, exception: InfluxDBError):
 with InfluxDBClient3.InfluxDBClient3(
         token="",
         host="eu-central-1-1.aws.cloud2.influxdata.com",
-        org="6a841c0c08328fb1",
         database="python", write_client_options=wco) as client:
     fpo = file_parser_options(columns=["time", "machineID", "vibration"])
 

Examples/flight_options_example.py

@@ -10,7 +10,6 @@
 client = InfluxDBClient3.InfluxDBClient3(
     token="",
     host="b0c7cce5-8dbc-428e-98c6-7f996fb96467.a.influxdb.io",
-    org="6a841c0c08328fb1",
     database="flightdemo",
     flight_client_options=flight_client_options(
         tls_root_certs=cert))

Examples/handle_http_error.py

@@ -18,7 +18,6 @@ def main() -> None:
     client = InfluxDBClient3.InfluxDBClient3(
         host=config.host,
         token=config.token,
-        org=config.org,
         database=config.database
     )
 

Examples/pandas_write.py

@@ -5,7 +5,6 @@
 client = InfluxDBClient3.InfluxDBClient3(
     token="",
     host="eu-central-1-1.aws.cloud2.influxdata.com",
-    org="",
     database="")
 
 

Examples/pokemon-trainer/basic-query.py

@@ -3,7 +3,6 @@
 client = InfluxDBClient3(
     token="",
     host="eu-central-1-1.aws.cloud2.influxdata.com",
-    org="6a841c0c08328fb1",
     database="pokemon-codex")
 
 sql = '''SELECT * FROM caught WHERE trainer = 'ash' AND time >= now() - interval '1 hour' LIMIT 5'''

Examples/pokemon-trainer/basic-write-errorhandling.py

@@ -7,7 +7,6 @@
 with InfluxDBClient3(
         token="",
         host="eu-central-1-1.aws.cloud2.influxdata.com",
-        org="6a841c0c08328fb1",
         database="pokemon-codex", write_client_options=wco) as client:
     now = datetime.datetime.now(datetime.timezone.utc)
 

Examples/pokemon-trainer/basic-write-writeoptions.py

@@ -7,7 +7,6 @@
 with InfluxDBClient3(
         token="",
         host="eu-central-1-1.aws.cloud2.influxdata.com",
-        org="6a841c0c08328fb1",
         database="pokemon-codex",
         write_client_options=wco,
         debug=True) as client:

Examples/pokemon-trainer/basic-write.py

@@ -5,7 +5,6 @@
 client = InfluxDBClient3(
     token="mGbL-OJ2kxYqvbIL9jQOOg2VJLhf16hh-xn-XJe3RUKrI5cewOAy80L5cVIzG0vh7dLLckZkpYfvExgoMBXLFA==",
     host="eu-central-1-1.aws.cloud2.influxdata.com",
-    org="6a841c0c08328fb1",
     database="pokemon-codex")
 
 now = datetime.datetime.now(datetime.timezone.utc)

Examples/pokemon-trainer/cookbook.ipynb

@@ -95,12 +95,11 @@
    "source": [
     "# In this example we are using the InfluxDBClient3 object to connect to the InfluxDB Cloud instance.\n",
     "# We are also passing in the write_client_options we created earlier.\n",
-    "# The token, host and org are all required to connect to the InfluxDB Serverless instance.\n",
+    "# The token and host are required to connect to the InfluxDB Serverless instance.\n",
     "# Note: that Org is optional with Dedicated instances.\n",
     "client = InfluxDBClient3(\n",
     "    token=\"phVXVXPBZ12vyNvVGJJX6vngFa4zyCYIzgDTYRJsPyIUSi3r78agctL2ksCH1GlUxtIWdGFWL5ScxQxUnbQOAQ==\",\n",
     "    host=\"eu-central-1-1.aws.cloud2.influxdata.com\",\n",
-    "    org=\"6a841c0c08328fb1\",\n",
     "    database=\"pokemon-codex\", enable_gzip=True, write_client_options=wco)\n",
     "\n",
     "now =  pd.Timestamp.now(tz='UTC').floor('ms')\n",

Examples/pokemon-trainer/pandas-write.py

@@ -7,7 +7,6 @@
 client = InfluxDBClient3(
     token="",
     host="eu-central-1-1.aws.cloud2.influxdata.com",
-    org="6a841c0c08328fb1",
     database="pokemon-codex")
 
 now = pd.Timestamp.now(tz='UTC').floor('ms')

Examples/pokemon-trainer/write-batching-flight-calloptions.py

@@ -39,7 +39,7 @@ def retry(self, conf, data: str, exception: InfluxDBError):
 client = InfluxDBClient3(
     token="",
     host="eu-central-1-1.aws.cloud2.influxdata.com",
-    org="6a841c0c08328fb1", enable_gzip=True, write_client_options=wco)
+    enable_gzip=True, write_client_options=wco)
 
 now = pd.Timestamp.now(tz='UTC').floor('ms')
 

Examples/pokemon-trainer/write-batching.py

@@ -36,7 +36,6 @@ def retry(self, conf, data: str, exception: InfluxDBError):
 client = InfluxDBClient3(
     token="",
     host="eu-central-1-1.aws.cloud2.influxdata.com",
-    org="6a841c0c08328fb1",
     database="pokemon-codex", enable_gzip=True, write_client_options=wco)
 
 now = pd.Timestamp.now(tz='UTC').floor('ms')

Examples/query_async.py

@@ -72,7 +72,6 @@ async def main():
         host=config.host,
         token=config.token,
         database=config.database,
-        org=config.org
     )
     measurement = 'example_uav'
     write_data(client, measurement)

Examples/query_type.py

@@ -3,7 +3,6 @@
 client = InfluxDBClient3.InfluxDBClient3(
     token="",
     host="eu-central-1-1.aws.cloud2.influxdata.com",
-    org="6a841c0c08328fb1",
     database="factory")
 
 

README.md

@@ -57,13 +57,11 @@ from influxdb_client_3 import InfluxDBClient3, Point
 
 ## Initialization
 If you are using InfluxDB Cloud, then you should note that:
-1. You will need to supply your org id, this is not necessary for InfluxDB Dedicated.
-2. Use bucket name for the `database` argument.
+1. Use bucket name for the `database` argument.
 
 ```python
 client = InfluxDBClient3(token="your-token",
                          host="your-host",
-                         org="your-org",
                          database="your-database")
 ```
 
@@ -124,7 +122,6 @@ wco = write_client_options(success_callback=callback.success,
 with  InfluxDBClient3.InfluxDBClient3(
     token="INSERT_TOKEN",
     host="eu-central-1-1.aws.cloud2.influxdata.com",
-    org="6a841c0c08328fb1",
     database="python", write_client_options=wco) as client:
 
 
@@ -171,27 +168,24 @@ Install `certifi`
 pip install certifi
 ```
 Next include certifi within the flight client options:
+
 ```python
+import certifi
+
 import influxdb_client_3 as InfluxDBClient3
-import pandas as pd
-import numpy as np
 from influxdb_client_3 import flight_client_options
-import certifi
 
 fh = open(certifi.where(), "r")
 cert = fh.read()
 fh.close()
 
-
 client = InfluxDBClient3.InfluxDBClient3(
     token="",
     host="b0c7cce5-8dbc-428e-98c6-7f996fb96467.a.influxdb.io",
-    org="6a841c0c08328fb1",
     database="flightdemo",
     flight_client_options=flight_client_options(
         tls_root_certs=cert))
 
-
 table = client.query(
     query="SELECT * FROM flight WHERE time > now() - 4h",
     language="influxql")

influxdb_client_3/query/query_api.py

@@ -104,7 +104,7 @@ class QueryApi(object):
 
 
             # Initialize instance of QueryApi
-            with InfluxDBClient(url="http://localhost:8086", token="my-token", org="my-org") as client:
+            with InfluxDBClient(url="http://localhost:8086", token="my-token") as client:
                 query_api = client.query_api()
     """
 

influxdb_client_3/write_client/client/influxdb_client.py

@@ -212,7 +212,7 @@ def write_api(self, write_options=WriteOptions(), point_settings=PointSettings()
 
 
                 # Initialize SYNCHRONOUS instance of WriteApi
-                with InfluxDBClient(url="http://localhost:8086", token="my-token", org="my-org") as client:
+                with InfluxDBClient(url="http://localhost:8086", token="my-token") as client:
                     write_api = client.write_api(write_options=SYNCHRONOUS)
 
         If you would like to use a **background batching**, you have to configure client like this:
@@ -222,7 +222,7 @@ def write_api(self, write_options=WriteOptions(), point_settings=PointSettings()
             from influxdb_client import InfluxDBClient
 
             # Initialize background batching instance of WriteApi
-            with InfluxDBClient(url="http://localhost:8086", token="my-token", org="my-org") as client:
+            with InfluxDBClient(url="http://localhost:8086", token="my-token") as client:
                 with client.write_api() as write_api:
                     pass
 
@@ -246,7 +246,7 @@ def retry(self, conf: (str, str, str), data: str, exception: InfluxDBError):
                     print(f"Retryable error occurs for batch: {conf}, data: {data} retry: {exception}")
 
 
-            with InfluxDBClient(url="http://localhost:8086", token="my-token", org="my-org") as client:
+            with InfluxDBClient(url="http://localhost:8086", token="my-token") as client:
                 callback = BatchingCallback()
                 with client.write_api(success_callback=callback.success,
                                       error_callback=callback.error,