U vi@sTdZddlmZddlmZddlmZddlmZddlm Z GdddeZ d S) z&Delete time series data from InfluxDB.)datetime)Union) Organization)_BaseDeleteApi)get_org_query_paramc sTeZdZdZfddZdeeefeeefeeeeedfe dddZ Z S) DeleteApiAsyncz3Async implementation for '/api/v2/delete' endpoint.cst|dS)zInitialize defaults.N)super__init__)selfinfluxdb_client __class__X/opt/alt/python38/lib/python3.8/site-packages/influxdb_client/client/delete_api_async.pyr szDeleteApiAsync.__init__N)startstop predicatebucketorgreturnc sD||||}t||jdd}|jj|||ddIdH}|ddkS)a Delete Time series data from InfluxDB. :param str, datetime.datetime start: start time :param str, datetime.datetime stop: stop time :param str predicate: predicate :param str bucket: bucket id or name from which data will be deleted :param str, Organization org: specifies the organization to delete data from. Take the ``ID``, ``Name`` or ``Organization``. If not specified the default value from ``InfluxDBClientAsync.org`` is used. :return: ``True`` for successfully deleted data, otherwise raise an exception F)rclientZ required_id)Zdelete_predicate_requestrrZ_return_http_data_onlyN)Z_prepare_predicate_requestrZ_influxdb_clientZ_serviceZpost_delete_async) r rrrrrZpredicate_requestZ org_paramresponserrrdeletes  zDeleteApiAsync.delete)N) __name__ __module__ __qualname____doc__r rstrrrboolr __classcell__rrr rr s  rN) rrtypingrr rZinfluxdb_client.client._baserZ#influxdb_client.client.util.helpersrrrrrrs