Skip to content
This repository was archived by the owner on Oct 29, 2024. It is now read-only.

Added list series and continuous queries #78

Merged
merged 1 commit into from
Nov 5, 2014
Merged

Added list series and continuous queries #78

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
52 changes: 52 additions & 0 deletions influxdb/client.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -324,6 +324,8 @@ def query(self, query, time_precision='s', chunked=False):

return response.json()



# Creating and Dropping Databases
#
# ### create a database
Expand Down Expand Up @@ -415,6 +417,56 @@ def delete_series(self, series):

return True

def get_series_list(self):
"""
Querying all time series in a database
"""

url = "db/{0}/series".format(self._database)

params = {
'q': 'list series'
'time_precision': 's',
'chunked': 'false'
}

response = self.request(
url=url,
method='GET',
params=params,
status_code=200
)
series_list = []
for series in response.json()[0]['points']:
series_list.append(series[1])

return series_list

def get_continuous_list(self):
"""
Querying all time series in a database
"""

url = "db/{0}/series".format(self._database)

params = {
'q': 'list continuous queries'
'time_precision': 's',
'chunked': 'false'
}

response = self.request(
url=url,
method='GET',
params=params,
status_code=200
)
series_list = []
for series in response.json()[0]['points']:
series_list.append(series[1])

return series_list

# Security
# get list of cluster admins
# curl http://localhost:8086/cluster_admins?u=root&p=root
Expand Down