@@ -124,7 +124,7 @@ def switch_user(self, username, password):
124
124
self ._password = password
125
125
126
126
def request (self , url , method = 'GET' , params = None , data = None ,
127
- status_code = 200 ):
127
+ expected_response_code = 200 ):
128
128
"""
129
129
Make a http request to API
130
130
"""
@@ -153,7 +153,7 @@ def request(self, url, method='GET', params=None, data=None,
153
153
timeout = self ._timeout
154
154
)
155
155
156
- if response .status_code == status_code :
156
+ if response .status_code == expected_response_code :
157
157
return response
158
158
else :
159
159
raise InfluxDBClientError (response .content , response .status_code )
@@ -231,7 +231,7 @@ def write_points_with_precision(self, data, time_precision='s'):
231
231
method = 'POST' ,
232
232
params = params ,
233
233
data = data ,
234
- status_code = 200
234
+ expected_response_code = 200
235
235
)
236
236
237
237
return True
@@ -247,7 +247,7 @@ def delete_points(self, name):
247
247
self .request (
248
248
url = url ,
249
249
method = 'DELETE' ,
250
- status_code = 204
250
+ expected_response_code = 204
251
251
)
252
252
253
253
return True
@@ -319,7 +319,7 @@ def query(self, query, time_precision='s', chunked=False):
319
319
url = url ,
320
320
method = 'GET' ,
321
321
params = params ,
322
- status_code = 200
322
+ expected_response_code = 200
323
323
)
324
324
325
325
return response .json ()
@@ -350,7 +350,7 @@ def create_database(self, database):
350
350
url = url ,
351
351
method = 'POST' ,
352
352
data = data ,
353
- status_code = 201
353
+ expected_response_code = 201
354
354
)
355
355
356
356
return True
@@ -370,7 +370,7 @@ def delete_database(self, database):
370
370
self .request (
371
371
url = url ,
372
372
method = 'DELETE' ,
373
- status_code = 204
373
+ expected_response_code = 204
374
374
)
375
375
376
376
return True
@@ -387,7 +387,7 @@ def get_database_list(self):
387
387
response = self .request (
388
388
url = url ,
389
389
method = 'GET' ,
390
- status_code = 200
390
+ expected_response_code = 200
391
391
)
392
392
393
393
return response .json ()
@@ -410,7 +410,7 @@ def delete_series(self, series):
410
410
self .request (
411
411
url = url ,
412
412
method = 'DELETE' ,
413
- status_code = 204
413
+ expected_response_code = 204
414
414
)
415
415
416
416
return True
@@ -478,7 +478,7 @@ def get_list_cluster_admins(self):
478
478
response = self .request (
479
479
url = "cluster_admins" ,
480
480
method = 'GET' ,
481
- status_code = 200
481
+ expected_response_code = 200
482
482
)
483
483
484
484
return response .json ()
@@ -496,7 +496,7 @@ def add_cluster_admin(self, new_username, new_password):
496
496
url = "cluster_admins" ,
497
497
method = 'POST' ,
498
498
data = data ,
499
- status_code = 200
499
+ expected_response_code = 200
500
500
)
501
501
502
502
return True
@@ -515,7 +515,7 @@ def update_cluster_admin_password(self, username, new_password):
515
515
url = url ,
516
516
method = 'POST' ,
517
517
data = data ,
518
- status_code = 200
518
+ expected_response_code = 200
519
519
)
520
520
521
521
return True
@@ -529,7 +529,7 @@ def delete_cluster_admin(self, username):
529
529
self .request (
530
530
url = url ,
531
531
method = 'DELETE' ,
532
- status_code = 200
532
+ expected_response_code = 200
533
533
)
534
534
535
535
return True
@@ -555,7 +555,7 @@ def alter_database_admin(self, username, is_admin):
555
555
url = url ,
556
556
method = 'POST' ,
557
557
data = data ,
558
- status_code = 200
558
+ expected_response_code = 200
559
559
)
560
560
561
561
return True
@@ -627,7 +627,7 @@ def get_database_users(self):
627
627
response = self .request (
628
628
url = url ,
629
629
method = 'GET' ,
630
- status_code = 200
630
+ expected_response_code = 200
631
631
)
632
632
633
633
return response .json ()
@@ -657,7 +657,7 @@ def add_database_user(self, new_username, new_password, permissions=None):
657
657
url = url ,
658
658
method = 'POST' ,
659
659
data = data ,
660
- status_code = 200
660
+ expected_response_code = 200
661
661
)
662
662
663
663
return True
@@ -676,7 +676,7 @@ def update_database_user_password(self, username, new_password):
676
676
url = url ,
677
677
method = 'POST' ,
678
678
data = data ,
679
- status_code = 200
679
+ expected_response_code = 200
680
680
)
681
681
682
682
if username == self ._username :
@@ -693,7 +693,7 @@ def delete_database_user(self, username):
693
693
self .request (
694
694
url = url ,
695
695
method = 'DELETE' ,
696
- status_code = 200
696
+ expected_response_code = 200
697
697
)
698
698
699
699
return True
0 commit comments