🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-08 17:12:14 | PHP 8.2.32
📂
/ (Root)
/
opt
/
alt
/
python38
/
lib
/
python3.8
/
site-packages
/
influxdb_client
/
client
/
__pycache__
📍 /opt/alt/python38/lib/python3.8/site-packages/influxdb_client/client/__pycache__
🔄 Refresh
✏️
Editing: bucket_api.cpython-38.pyc
Read Only
U v�i� � @ sP d Z ddlZddlmZmZmZmZ ddlmZ ddl m Z G dd� de �Z dS )z� A bucket is a named location where time series data is stored. All buckets have a retention policy, a duration of time that each data point persists. A bucket belongs to an organization. � N)�BucketsService�Bucket�PostBucketRequest�PatchBucketRequest)�get_org_query_param)� _Paginatedc @ s` e Zd ZdZdd� Zded�dd�Zeed�d d �Zd d � Zd d� Z dd� Z dd� Z dd� Z dS )� BucketsApiz.Implementation for '/api/v2/buckets' endpoint.c C s || _ t|j�| _dS )zInitialize defaults.N)�_influxdb_clientr Z api_client�_buckets_service)�self�influxdb_client� r �R/opt/alt/python38/lib/python3.8/site-packages/influxdb_client/client/bucket_api.py�__init__ s zBucketsApi.__init__N)�returnc C s� |dkr g }g }t |t�r&|�|� n |�|� |dk rDt�dt� |dkrtt|||t|dkrb|n|| j dd�d�}| j j |d�S )a� Create a bucket. :param Bucket|PostBucketRequest bucket: bucket to create :param bucket_name: bucket name :param description: bucket description :param org_id: org_id :param bucket_name: bucket name :param retention_rules: retention rules array or single BucketRetentionRules :param str, Organization org: specifies the organization for create the bucket; Take the ``ID``, ``Name`` or ``Organization``. If not specified the default value from ``InfluxDBClient.org`` is used. :return: Bucket If the method is called asynchronously, returns the request thread. Nz org_id is deprecated; use orgT)�org�clientZ required_id)�name�retention_rules� description�org_id)Zpost_bucket_request) � isinstance�list�extend�append�warnings�warn�DeprecationWarningr r r r Z post_buckets)r �bucket� bucket_namer r r r �rulesr r r � create_bucket s$ ��zBucketsApi.create_bucket)r r c C s& t |j|j|jd�}| jj|j|d�S )zkUpdate a bucket. :param bucket: Bucket update to apply (required) :return: Bucket )r r r )� bucket_idZpatch_bucket_request)r r r r r Zpatch_buckets_id�id)r r �requestr r r � update_bucket> s �zBucketsApi.update_bucketc C s$ t |t�r|j}n|}| jj|d�S )z]Delete a bucket. :param bucket: bucket id or Bucket :return: Bucket )r" )r r r# r Zdelete_buckets_id)r r r" r r r � delete_bucketJ s zBucketsApi.delete_bucketc C s | j �|�S )z@Find bucket by ID. :param id: :return: )r Zget_buckets_id)r r# r r r �find_bucket_by_idW s z BucketsApi.find_bucket_by_idc C s. | j j|d�}t|j�dkr&|jd S dS dS )z^Find bucket by name. :param bucket_name: bucket name :return: Bucket )r r N)r � get_buckets�len�buckets)r r r* r r r �find_bucket_by_name_ s z BucketsApi.find_bucket_by_namec K s | j jf |�S )a� List buckets. :key int offset: Offset for pagination :key int limit: Limit for pagination :key str after: The last resource ID from which to seek from (but not including). This is to be used instead of `offset`. :key str org: The organization name. :key str org_id: The organization ID. :key str name: Only returns buckets with a specific name. :return: Buckets )r r( �r �kwargsr r r � find_bucketsl s zBucketsApi.find_bucketsc K s t | jjdd� �jf |�S )a� Iterate over all buckets with pagination. :key str name: Only returns buckets with the specified name :key str org: The organization name. :key str org_id: The organization ID. :key str after: The last resource ID from which to seek from (but not including). :key int limit: the maximum number of buckets in one page :return: Buckets iterator c S s | j S )N)r* )�responser r r �<lambda>� � z.BucketsApi.find_buckets_iter.<locals>.<lambda>)r r r( Z find_iterr, r r r �find_buckets_iterz s z BucketsApi.find_buckets_iter)NNNNNN) �__name__� __module__� __qualname__�__doc__r r r! r% r& r' r+ r. r2 r r r r r s �� ( r ) r6 r r r r r r Z#influxdb_client.client.util.helpersr Z influxdb_client.client._pagesr �objectr r r r r �<module> s
💾 Save Changes
❌ Cancel