Merge pull request #6 from AgarFu/master

Use requests sessions to improve performance

Author: AstinCHOI

akamai/netstorage/netstorage.py

@@ -47,6 +47,7 @@ def __init__(self, hostname, keyname, key, ssl=False):
         self.keyname = keyname
         self.key = key
         self.ssl = 's' if ssl else ''
+        self.http_client = requests.Session()
 
 
     def _download_data_from_response(self, response, ns_path, local_destination, chunk_size=16*1024):
@@ -105,21 +106,21 @@ def _request(self, **kwargs):
         response = None
         if kwargs['method'] == 'GET':
             if kwargs['action'] == 'download':
-                response = requests.get(request_url, headers=headers, stream=True)
+                response = self.http_client.get(request_url, headers=headers, stream=True)
                 if 'stream' not in kwargs.keys():
                     self._download_data_from_response(response, kwargs['path'], kwargs['destination'])
             else:
-                response = requests.get(request_url, headers=headers)
+                response = self.http_client.get(request_url, headers=headers)
 
         elif kwargs['method'] == 'POST':
-            response = requests.post(request_url, headers=headers)
+            response = self.http_client.post(request_url, headers=headers)
 
         elif kwargs['method'] == 'PUT': # Use only upload
             if 'stream' in kwargs.keys():
-                response = requests.put(request_url, headers=headers, data=kwargs['stream'])
+                response = self.http_client.put(request_url, headers=headers, data=kwargs['stream'])
             elif kwargs['action'] == 'upload':
                 mmapped_data = self._upload_data_to_request(kwargs['source'])
-                response = requests.put(request_url, headers=headers, data=mmapped_data)
+                response = self.http_client.put(request_url, headers=headers, data=mmapped_data)
                 mmapped_data.close()
 
         return response.status_code == 200, response
@@ -210,4 +211,4 @@ def stream_upload(self, data, ns_destination):
         return self._request(action='upload',
                             method='PUT',
                             stream=data,
-                            path=ns_destination)
+                            path=ns_destination)

setup.py

@@ -8,7 +8,7 @@
 
 setup (
     name = 'netstorageapi',
-    version = '1.2.8',
+    version = '1.2.9',
     description = 'Akamai Netstorage API for Python',
     long_description = readme,
     namespace_packages=['akamai'],
@@ -33,4 +33,4 @@
         'Programming Language :: Python :: Implementation :: CPython',
         'Programming Language :: Python :: Implementation :: PyPy'
     ),
-)
+)