10000 added write client files · InfluxCommunity/influxdb3-python@505fe01 · GitHub
[go: up one dir, main page]
Skip to content

Commit 505fe01

Browse files
author
Jay Clifford
committed
added write client files
1 parent 99a17d1 commit 505fe01

34 files changed

+4677
-12
lines changed

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@
33

44

55
client = InfluxDBClient3(
6-
token="",
6+
token="mGbL-OJ2kxYqvbIL9jQOOg2VJLhf16hh-xn-XJe3RUKrI5cewOAy80L5cVIzG0vh7dLLckZkpYfvExgoMBXLFA==",
77
host="eu-central-1-1.aws.cloud2.influxdata.com",
88
org="6a841c0c08328fb1",
99
database="pokemon-codex")

‎influxdb_client_3/__init__.py

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,9 +1,9 @@
11
import urllib.parse, json
22
import pyarrow as pa
3-
from influxdb_client import InfluxDBClient as _InfluxDBClient, WriteOptions, Point
4-
from influxdb_client.client.write_api import WriteApi as _WriteApi, SYNCHRONOUS, ASYNCHRONOUS, PointSettings
5-
from influxdb_client.domain.write_precision import WritePrecision
6-
from influxdb_client.client.exceptions import InfluxDBError
3+
from write_client import InfluxDBClient as _InfluxDBClient, WriteOptions, Point
4+
from write_client.write_api.write_api import WriteApi as _WriteApi, SYNCHRONOUS, ASYNCHRONOUS, PointSettings
5+
from write_client.domain.write_precision import WritePrecision
6+
from write_client.write_api.exceptions import InfluxDBError
77
from pyarrow.flight import FlightClient, Ticket, FlightCallOptions
88
from influxdb_client_3.read_file import UploadFile
99

‎influxdb_client_3/read_file.py

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -3,6 +3,10 @@
33
import pyarrow.feather as feather
44
import pyarrow.parquet as parquet
55

6+
try:
7+
import pandas as pd
8+
except ImportError:
9+
raise ImportError("Pandas is required for write_file(). Please install it using 'pip install pandas' or 'pip install influxdb3-python[pandas]'")
610

711

812

@@ -23,10 +27,6 @@ def __init__(self, file, file_parser_options=None):
2327
:type file: str
2428
:param kwargs: Additional arguments for file loading functions.
2529
"""
26-
try:
27-
import pandas as pd
28-
except ImportError:
29-
raise ImportError("Pandas is required for write_file(). Please install it using 'pip install pandas' or 'pip install influxdb3-python[pandas]'")
3030

3131
self._file = file
3232
self._kwargs = file_parser_options if file_parser_options is not None else {}

‎influxdb_client_3/write_client/__init__.py

Lines changed: 32 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,32 @@
1+
# coding: utf-8
2+
3+
# flake8: noqa
4+
5+
"""
6+
InfluxDB OSS API Service.
7+
8+
The InfluxDB v2 API provides a programmatic interface for all interactions with InfluxDB. Access the InfluxDB API using the `/api/v2/` endpoint. # noqa: E501
9+
10+
OpenAPI spec version: 2.0.0
11+
Generated by: https://openapi-generator.tech
12+
"""
13+
14+
15+
from __future__ import absolute_import
16+
17+
from write_client.write_api.write_api import WriteApi, WriteOptions
18+
from write_client.write_api.influxdb_client import InfluxDBClient
19+
from write_client.write_api.logging_handler import InfluxLoggingHandler
20+
from write_client.write_api.write.point import Point
21+
22+
from write_client.service.write_service import WriteService
23+
from write_client.service.signin_service import SigninService
24+
from write_client.service.signout_service import SignoutService
25+
26+
from write_client.domain.write_precision import WritePrecision
27+
28+
29+
from write_client.configuration import Configuration
30+
from write_client.write_api.influxdb_client import InfluxDBClient
31+
from write_client.version import VERSION
32+
__version__ = VERSION

‎influxdb_client_3/write_client/_sync/__init__.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1 @@
1+
"""Synchronous REST APIs."""

0 commit comments

Comments
 (0)
0