31
31
#
32
32
33
33
34
- import urllib2
35
34
import json
36
35
import time
37
36
import socket
37
+ import base64
38
+
39
+ try :
40
+ from urllib .request import (Request ,
41
+ urlopen )
42
+ except ImportError :
43
+ from urllib2 import (Request ,
44
+ urlopen )
38
45
39
46
user = "admin"
40
47
password = "targetd"
@@ -43,7 +50,7 @@ port = 18700
43
50
path = '/targetrpc'
44
51
id_num = 1
45
52
ssl = False
46
- pool = 'vg-targetd'
53
+ pool = 'vg-targetd/thin_pool '
47
54
48
55
49
56
def jsonrequest (method , params = None ):
@@ -52,7 +59,8 @@ def jsonrequest(method, params=None):
52
59
data = json .dumps (
53
60
dict (id = id_num , method = method , params = params , jsonrpc = "2.0" ))
54
61
id_num += 1
55
- auth = ('%s:%s' % (user , password )).encode ('base64' )[:- 1 ]
62
+ username_pass = '%s:%s' % (user , password )
63
+ auth = base64 .b64encode (username_pass .encode ('utf-8' )).decode ('utf-8' )
56
64
headers = {'Content-Type' : 'application/json' ,
57
65
'Authorization' : 'Basic %s' % (auth ,)}
58
66
#print('Sending JSON data: %s' % data)
@@ -62,14 +70,14 @@ def jsonrequest(method, params=None):
62
70
scheme = 'http'
63
71
url = "%s://%s:%s%s" % (scheme , host , port , path )
64
72
try :
65
- request = urllib2 . Request (url , data , headers )
66
- response_obj = urllib2 . urlopen (request )
73
+ request = Request (url , data . encode ( 'utf-8' ) , headers )
74
+ response_obj = urlopen (request )
67
75
except socket .error as e :
68
76
print ("error, retrying with SSL" )
69
77
url = "https://%s:%s%s" % (host , port , path )
70
- request = urllib2 . Request (url , data , headers )
71
- response_obj = urllib2 . urlopen (request )
72
- response_data = response_obj .read ()
78
+ request = Request (url , data , headers )
79
+ response_obj = urlopen (request )
80
+ response_data = response_obj .read (). decode ( 'utf-8' )
73
81
#print('Got response: %s' % response_data)
74
82
response = json .loads (response_data )
75
83
if response .get ('error' ) is not None :
0 commit comments