|
@@ 417-427 (lines=11) @@
|
| 414 |
|
print(info) |
| 415 |
|
assert ret['key'] == key |
| 416 |
|
|
| 417 |
|
def test_big_file(self): |
| 418 |
|
key = 'big' |
| 419 |
|
token = self.q.upload_token(bucket_name, key) |
| 420 |
|
localfile = create_temp_file(4 * 1024 * 1024 + 1) |
| 421 |
|
progress_handler = lambda progress, total: progress |
| 422 |
|
qiniu.set_default(default_zone=Zone('a', 'upload.qiniu.com')) |
| 423 |
|
ret, info = put_file(token, key, localfile, self.params, self.mime_type, progress_handler=progress_handler) |
| 424 |
|
print(info) |
| 425 |
|
assert ret['key'] == key |
| 426 |
|
qiniu.set_default(default_zone=qiniu.config.zone0) |
| 427 |
|
remove_temp_file(localfile) |
| 428 |
|
|
| 429 |
|
def test_retry(self): |
| 430 |
|
localfile = __file__ |
|
@@ 429-438 (lines=10) @@
|
| 426 |
|
qiniu.set_default(default_zone=qiniu.config.zone0) |
| 427 |
|
remove_temp_file(localfile) |
| 428 |
|
|
| 429 |
|
def test_retry(self): |
| 430 |
|
localfile = __file__ |
| 431 |
|
key = 'test_file_r_retry' |
| 432 |
|
qiniu.set_default(default_zone=Zone('a', 'upload.qiniu.com')) |
| 433 |
|
token = self.q.upload_token(bucket_name, key) |
| 434 |
|
ret, info = put_file(token, key, localfile, self.params, self.mime_type) |
| 435 |
|
print(info) |
| 436 |
|
assert ret['key'] == key |
| 437 |
|
assert ret['hash'] == etag(localfile) |
| 438 |
|
qiniu.set_default(default_zone=qiniu.config.zone0) |
| 439 |
|
|
| 440 |
|
|
| 441 |
|
class DownloadTestCase(unittest.TestCase): |
|
@@ 336-345 (lines=10) @@
|
| 333 |
|
assert ret['hash'] == 'FlYu0iBR1WpvYi4whKXiBuQpyLLk' |
| 334 |
|
qiniu.set_default(default_zone=qiniu.config.zone0) |
| 335 |
|
|
| 336 |
|
def test_hasRead_hasSeek_retry(self): |
| 337 |
|
key = 'withReadAndSeek_retry' |
| 338 |
|
data = StringIO('hello retry again!') |
| 339 |
|
set_default(default_zone=Zone('a', 'upload.qiniu.com')) |
| 340 |
|
token = self.q.upload_token(bucket_name) |
| 341 |
|
ret, info = put_data(token, key, data) |
| 342 |
|
print(info) |
| 343 |
|
assert ret['key'] == key |
| 344 |
|
assert ret['hash'] == 'FuEbdt6JP2BqwQJi7PezYhmuVYOo' |
| 345 |
|
qiniu.set_default(default_zone=qiniu.config.zone0) |
| 346 |
|
|
| 347 |
|
def test_hasRead_withoutSeek_retry(self): |
| 348 |
|
key = 'withReadAndWithoutSeek_retry' |
|
@@ 325-334 (lines=10) @@
|
| 322 |
|
assert ret is None |
| 323 |
|
assert info.status_code == 403 # key not match |
| 324 |
|
|
| 325 |
|
def test_withoutRead_withoutSeek_retry(self): |
| 326 |
|
key = 'retry' |
| 327 |
|
data = 'hello retry!' |
| 328 |
|
set_default(default_zone=Zone('a', 'upload.qiniu.com')) |
| 329 |
|
token = self.q.upload_token(bucket_name) |
| 330 |
|
ret, info = put_data(token, key, data) |
| 331 |
|
print(info) |
| 332 |
|
assert ret['key'] == key |
| 333 |
|
assert ret['hash'] == 'FlYu0iBR1WpvYi4whKXiBuQpyLLk' |
| 334 |
|
qiniu.set_default(default_zone=qiniu.config.zone0) |
| 335 |
|
|
| 336 |
|
def test_hasRead_hasSeek_retry(self): |
| 337 |
|
key = 'withReadAndSeek_retry' |