|
22 | 22 | import io |
23 | 23 | import csv |
24 | 24 | import sys |
| 25 | +import tempfile |
25 | 26 |
|
26 | 27 | from sys import exit |
27 | 28 | import uuid |
@@ -895,22 +896,25 @@ def test_fget_object(client, log_output, sse=None): |
895 | 896 | # default value for log_output.function attribute is; |
896 | 897 | # log_output.function = "fget_object(bucket_name, object_name, file_path, request_headers)" |
897 | 898 |
|
| 899 | + tmpfd, tmpfile = tempfile.mkstemp() |
| 900 | + os.close(tmpfd) |
| 901 | + |
898 | 902 | # Get a unique bucket_name and object_name |
899 | 903 | log_output.args['bucket_name'] = bucket_name = generate_bucket_name() |
900 | 904 | log_output.args['object_name'] = object_name = uuid.uuid4().__str__() |
901 | | - log_output.args['file_path'] = newfile_f = 'newfile-f 新' |
| 905 | + log_output.args['file_path'] = tmpfile |
902 | 906 | try: |
903 | 907 | MB_1 = 1024*1024 # 1MiB. |
904 | 908 | MB_1_reader = LimitedRandomReader(MB_1) |
905 | 909 | client.make_bucket(bucket_name) |
906 | 910 | client.put_object(bucket_name, object_name, MB_1_reader, MB_1, sse=sse) |
907 | 911 | # Get/Download a full object and save locally at path |
908 | | - client.fget_object(bucket_name, object_name, newfile_f, sse=sse) |
| 912 | + client.fget_object(bucket_name, object_name, tmpfile, sse=sse) |
909 | 913 | except Exception as err: |
910 | 914 | raise Exception(err) |
911 | 915 | finally: |
912 | 916 | try: |
913 | | - os.remove(newfile_f) |
| 917 | + os.remove(tmpfile) |
914 | 918 | client.remove_object(bucket_name, object_name) |
915 | 919 | client.remove_bucket(bucket_name) |
916 | 920 | except Exception as err: |
@@ -1877,6 +1881,7 @@ def main(): |
1877 | 1881 | Functional testing of minio python library. |
1878 | 1882 | """ |
1879 | 1883 |
|
| 1884 | + |
1880 | 1885 | try: |
1881 | 1886 | access_key = os.getenv('ACCESS_KEY', 'Q3AM3UQ867SPQQA43P2F') |
1882 | 1887 | secret_key = os.getenv('SECRET_KEY', |
|
0 commit comments