@@ -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
@@ -453,7 +453,7 @@ def get_list_cluster_admins(self):
453
453
response = self .request (
454
454
url = "cluster_admins" ,
455
455
method = 'GET' ,
456
- status_code = 200
456
+ expected_response_code = 200
457
457
)
458
458
459
459
return response .json ()
@@ -471,7 +471,7 @@ def add_cluster_admin(self, new_username, new_password):
471
471
url = "cluster_admins" ,
472
472
method = 'POST' ,
473
473
data = data ,
474
- status_code = 200
474
+ expected_response_code = 200
475
475
)
476
476
477
477
return True
@@ -490,7 +490,7 @@ def update_cluster_admin_password(self, username, new_password):
490
490
url = url ,
491
491
method = 'POST' ,
492
492
data = data ,
493
- status_code = 200
493
+ expected_response_code = 200
494
494
)
495
495
496
496
return True
@@ -504,7 +504,7 @@ def delete_cluster_admin(self, username):
504
504
self .request (
505
505
url = url ,
506
506
method = 'DELETE' ,
507
- status_code = 200
507
+ expected_response_code = 200
508
508
)
509
509
510
510
return True
@@ -530,7 +530,7 @@ def alter_database_admin(self, username, is_admin):
530
530
url = url ,
531
531
method = 'POST' ,
532
532
data = data ,
533
- status_code = 200
533
+ expected_response_code = 200
534
534
)
535
535
536
536
return True
@@ -602,7 +602,7 @@ def get_database_users(self):
602
602
response = self .request (
603
603
url = url ,
604
604
method = 'GET' ,
605
- status_code = 200
605
+ expected_response_code = 200
606
606
)
607
607
608
608
return response .json ()
@@ -632,7 +632,7 @@ def add_database_user(self, new_username, new_password, permissions=None):
632
632
url = url ,
633
633
method = 'POST' ,
634
634
data = data ,
635
- status_code = 200
635
+ expected_response_code = 200
636
636
)
637
637
638
638
return True
@@ -651,7 +651,7 @@ def update_database_user_password(self, username, new_password):
651
651
url = url ,
652
652
method = 'POST' ,
653
653
data = data ,
654
- status_code = 200
654
+ expected_response_code = 200
655
655
)
656
656
657
657
if username == self ._username :
@@ -668,7 +668,7 @@ def delete_database_user(self, username):
668
668
self .request (
669
669
url = url ,
670
670
method = 'DELETE' ,
671
- status_code = 200
671
+ expected_response_code = 200
672
672
)
673
673
674
674
return True
0 commit comments