Skip to content

Instantly share code, notes, and snippets.

@imbriaco
Created February 2, 2009 17:07
Show Gist options
  • Save imbriaco/56982 to your computer and use it in GitHub Desktop.
Save imbriaco/56982 to your computer and use it in GitHub Desktop.
#!/usr/bin/env python
import cloudfiles
from threading import Thread
conn = cloudfiles.get_connection('xxx', 'yyy')
container = conn.get_container('zzz')
def upload_file(num):
file = container.create_object('test.512m.' + str(num))
file.content_type = 'application/octet-stream'
file.load_from_filename('/tmp/test.512m.' + str(num))
for i in range(1,5):
worker = Thread(target = upload_file, args=(i,))
worker.start()
Exception in thread Thread-2:
Traceback (most recent call last):
File "/usr/lib64/python2.4/threading.py", line 442, in __bootstrap
self.run()
File "/usr/lib64/python2.4/threading.py", line 422, in run
self.__target(*self.__args, **self.__kwargs)
File "cfput.py", line 10, in upload_file
file = container.create_object('test.512m.' + str(num))
File "/usr/lib/python2.4/site-packages/cloudfiles/utils.py", line 39, in decorator
return f(*args, **kwargs)
File "/usr/lib/python2.4/site-packages/cloudfiles/container.py", line 156, in create_object
return Object(self, object_name)
File "/usr/lib/python2.4/site-packages/cloudfiles/storage_object.py", line 68, in __init__
if not self._initialize() and force_exists:
File "/usr/lib/python2.4/site-packages/cloudfiles/storage_object.py", line 374, in _initialize
response = self.container.conn.make_request(
File "/usr/lib/python2.4/site-packages/cloudfiles/connection.py", line 152, in make_request
self.connection.request(method, path, data, headers)
File "/usr/lib64/python2.4/httplib.py", line 810, in request
self._send_request(method, url, body, headers)
File "/usr/lib64/python2.4/httplib.py", line 827, in _send_request
self.putrequest(method, url, **skips)
File "/usr/lib64/python2.4/httplib.py", line 723, in putrequest
raise CannotSendRequest()
CannotSendRequest
Exception in thread Thread-3:
Traceback (most recent call last):
File "/usr/lib64/python2.4/threading.py", line 442, in __bootstrap
self.run()
File "/usr/lib64/python2.4/threading.py", line 422, in run
self.__target(*self.__args, **self.__kwargs)
File "cfput.py", line 10, in upload_file
file = container.create_object('test.512m.' + str(num))
File "/usr/lib/python2.4/site-packages/cloudfiles/utils.py", line 39, in decorator
return f(*args, **kwargs)
File "/usr/lib/python2.4/site-packages/cloudfiles/container.py", line 156, in create_object
return Object(self, object_name)
File "/usr/lib/python2.4/site-packages/cloudfiles/storage_object.py", line 68, in __init__
if not self._initialize() and force_exists:
File "/usr/lib/python2.4/site-packages/cloudfiles/storage_object.py", line 374, in _initialize
response = self.container.conn.make_request(
File "/usr/lib/python2.4/site-packages/cloudfiles/connection.py", line 152, in make_request
self.connection.request(method, path, data, headers)
File "/usr/lib64/python2.4/httplib.py", line 810, in request
self._send_request(method, url, body, headers)
File "/usr/lib64/python2.4/httplib.py", line 827, in _send_request
self.putrequest(method, url, **skips)
File "/usr/lib64/python2.4/httplib.py", line 723, in putrequest
raise CannotSendRequest()
CannotSendRequest
Exception in thread Thread-4:
Traceback (most recent call last):
File "/usr/lib64/python2.4/threading.py", line 442, in __bootstrap
self.run()
File "/usr/lib64/python2.4/threading.py", line 422, in run
self.__target(*self.__args, **self.__kwargs)
File "cfput.py", line 10, in upload_file
file = container.create_object('test.512m.' + str(num))
File "/usr/lib/python2.4/site-packages/cloudfiles/utils.py", line 39, in decorator
return f(*args, **kwargs)
File "/usr/lib/python2.4/site-packages/cloudfiles/container.py", line 156, in create_object
return Object(self, object_name)
File "/usr/lib/python2.4/site-packages/cloudfiles/storage_object.py", line 68, in __init__
if not self._initialize() and force_exists:
File "/usr/lib/python2.4/site-packages/cloudfiles/storage_object.py", line 374, in _initialize
response = self.container.conn.make_request(
File "/usr/lib/python2.4/site-packages/cloudfiles/connection.py", line 152, in make_request
self.connection.request(method, path, data, headers)
File "/usr/lib64/python2.4/httplib.py", line 810, in request
self._send_request(method, url, body, headers)
File "/usr/lib64/python2.4/httplib.py", line 827, in _send_request
self.putrequest(method, url, **skips)
File "/usr/lib64/python2.4/httplib.py", line 723, in putrequest
raise CannotSendRequest()
CannotSendRequest
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment