帮助文档
搜全部 搜本产品
全部产品
弹性计算 会员服务 网络 安全 移动云 数加·大数据分析及展现 数加·大数据应用 管理与监控 云通信 阿里云办公 培训与认证 智能硬件
存储与CDN 数据库 域名与网站(万网) 应用服务 数加·人工智能 数加·大数据基础服务 互联网中间件 视频服务 开发者工具 解决方案 物联网 更多
对象存储 OSS

管理文件

更新时间：2017-06-07 13:26:11

查看所有文件

通过oss_list_object接口，可以列出当前存储空间下的所有文件。

  1. aos_pool_t *p;
  2. oss_request_options_t *options;
  3. aos_status_t *s;
  4. aos_table_t *resp_headers;
  5. char *bucket_name = "<您的bucket名字>";
  6. aos_string_t bucket;
  7. oss_list_object_params_t *params;
  8. oss_list_object_content_t *content;
  9. int max_ret = 1000;
  10. char *key;
  12. aos_pool_create(&p, NULL);
  14. options = oss_request_options_create(p);
  15. init_options(options);
  17. aos_str_set(&bucket, bucket_name);
  18. params = oss_create_list_object_params(p);
  19. params->max_ret = max_ret;
  20. aos_str_set(&params->prefix, "<查看文件的前缀>");
  21. aos_str_set(&params->delimiter, "<查看文件的分隔符>");
  22. aos_str_set(&params->marker, "<查看文件的起点>");
  24. s = oss_list_object(options, &bucket, params, &resp_headers);
  25. if (aos_status_is_ok(s)) {
  26.     printf("get object succeeded\n");
  28.     /* 下载文件 */
  29.     aos_list_for_each_entry(content, &params->object_list, node) {
  30.     key = apr_psprintf(p, "%.*s", content->key.len, content->key.data);
  31.     }
  32. } else {
  33.     printf("get object failed\n");
  34. }
  36. aos_pool_destroy(p);

注：

  • 默认情况下，如果存储空间中的文件数量大于1000，则只会返回1000个文件， 且返回结果中 truncated为true，并返回next_marker作为下此读取的起点。若想增大返回文件数目，可以修改 max_ret参数，或者使用marker参数分次读取。
  • 完整代码参考：GitHub

创建模拟目录

OSS是基于对象的存储服务，没有目录的概念。创建模拟目录本质上来说是创建了一个size为0的文件。对于这个文件照样可以上传下载,只是控制台会对以”/“结尾的文件以文件夹的方式展示，所以用户可以使用上述方式来实现创建模拟目录。

  1. aos_pool_t *p;
  2. oss_request_options_t *options;
  3. aos_status_t *s;
  4. aos_table_t *headers;
  5. aos_table_t *resp_headers;
  6. char *bucket_name = "<您的bucket名字>";
  7. char *object_name = "<您的文件夹名字/>";
  8. aos_string_t bucket;
  9. aos_string_t object;
  10. char *data = "";
  11. aos_list_t buffer;
  12. aos_buf_t *content;
  14. aos_pool_create(&p, NULL);
  16. options = oss_request_options_create(p);
  17. init_options(options);
  19. aos_str_set(&bucket, bucket_name);
  20. aos_str_set(&object, object_name);
  21. headers = aos_table_make(p, 0);
  23. aos_list_init(&buffer);
  24. content = aos_buf_pack(options->pool, data, strlen(data));
  25. aos_list_add_tail(&content->node, &buffer);
  26. s = oss_put_object_from_buffer(options, &bucket, &object, &buffer, headers, &resp_headers);
  27. if (aos_status_is_ok(s)) {
  28.     printf("create dir succeeded\n");
  29. } else {
  30.     printf("create dir failed\n");
  31. }
  32. aos_pool_destroy(p);

注：

设定Object的Http Header

向OSS上传文件时，除了文件内容，还可以指定文件的一些属性信息，称为“元信息”。这些信息在上传时与文件一起存储，在下载时与文件一起返回。下面代码为文件设置了过期时间：

  1. aos_pool_t *p;
  2. oss_request_options_t *options;
  3. aos_status_t *s;
  4. aos_table_t *headers;
  5. aos_table_t *resp_headers;
  6. char *bucket_name = "<您的bucket名字>";
  7. char *object_name = "<您的object名字>";
  8. aos_string_t bucket;
  9. aos_string_t object;
  10. char *data = "<object content>";
  11. aos_list_t buffer;
  12. aos_buf_t *content;
  14. aos_pool_create(&p, NULL);
  16. options = oss_request_options_create(p);
  17. init_options(options);
  19. aos_str_set(&object, object_name);
  20. aos_str_set(&bucket, bucket_name);
  21. headers = aos_table_make(p, 0);
  23. /* 设置http header */
  24. headers = aos_table_make(p, 1);
  25. apr_table_set(headers, "Expires", "Fri, 28 Feb 2012 05:38:42 GMT"); 
  27. /* 读取数据到buffer中 */
  28. aos_list_init(&buffer);
  29. content = aos_buf_pack(options->pool, data, strlen(data));
  30. aos_list_add_tail(&content->node, &buffer);
  31. s = oss_put_object_from_buffer(options, &bucket, &object, &buffer, headers, &resp_headers);
  32. if (aos_status_is_ok(s)) {
  33.     printf("put object succeeded\n");
  34. } else {
  35.     printf("put object failed\n");
  36. }
  38. aos_pool_destroy(p);

注：

  • 可以设置Http Header有：Cache-Control 、 Content-Disposition 、Content-Encoding、 Expires 。它们的相关介绍见 RFC2616 。
  • 完整代码参考：GitHub

设置User Meta

OSS支持用户自定义Meta信息对文件进行描述。比如：

  1. aos_pool_t *p;
  2. oss_request_options_t *options;
  3. aos_status_t *s;
  4. aos_table_t *headers;
  5. aos_table_t *resp_headers;
  6. char *bucket_name = "<您的bucket名字>";
  7. char *object_name = "<您的object名字>";
  8. aos_string_t bucket;
  9. aos_string_t object;
  10. char *data = "<object content>";
  11. aos_list_t buffer;
  12. aos_buf_t *content;
  14. aos_pool_create(&p, NULL);
  16. options = oss_request_options_create(p);
  17. init_options(options);
  19. aos_str_set(&bucket, bucket_name);
  20. aos_str_set(&object, object_name);
  21. headers = aos_table_make(p, 1);
  23. /* 设置用户自定义meta */
  24. apr_table_set(headers, "x-oss-meta-author", "oss");
  26. /* 上传数据到OSS中 */
  27. aos_list_init(&buffer);
  28. content = aos_buf_pack(options->pool, data, strlen(data));
  29. aos_list_add_tail(&content->node, &buffer);
  30. s = oss_put_object_from_buffer(options, &bucket, &object, &buffer, headers, &resp_headers);
  31. if (aos_status_is_ok(s)) {
  32.     printf("put object succeeded\n");
  33. } else {
  34.     printf("put object failed\n");
  35. }
  36. aos_pool_destroy(p);

注：

  • 因为文件元信息在上传/下载时是附在HTTP Headers中， HTTP协议规定不能包含复杂字符。
  • 一个文件可以有多个类似的参数，但所有的user meta总大小不能超过8KB。

获取文件的元数据

有时候，再向OSS上传文件后或者读取文件前需要获取文件的一些元数据，比如长度，文件类型等，这时候可以通过oss_object_head接口获取文件的元数据。下面代码获取文件的长度和文件类型：

  1. void head_object()
  2. {
  3.     aos_pool_t *p = NULL;
  4.     aos_string_t bucket;
  5.     aos_string_t object;
  6.     oss_request_options_t *options = NULL;
  7.     aos_table_t *headers = NULL;
  8.     aos_table_t *resp_headers = NULL;
  9.     aos_status_t *s = NULL;
  10.     char *content_length_str = NULL;
  11.     char *object_type = NULL;
  12.     int64_t content_length = 0;
  14.     aos_pool_create(&p, NULL);
  16.     /* 创建并初始化options */
  17.     options = oss_request_options_create(p);
  18.     init_options(options);
  20.     /* 初始化参数 */
  21.     aos_str_set(&bucket, "<您的bucket名字>");
  22.     aos_str_set(&object, "<您的object名字>");
  23.     headers = aos_table_make(p, 0);
  25.     /* 获取文件元数据 */
  26.     s = oss_head_object(options, &bucket, &object, headers, &resp_headers);
  28.     if (aos_status_is_ok(s)) {
  29.         /* 获取文件长度 */
  30.         content_length_str = (char*)apr_table_get(resp_headers, OSS_CONTENT_LENGTH);
  31.         if (content_length_str != NULL) {
  32.             content_length = atoll(content_length_str);
  33.         }
  35.         /* 获取文件的类型 */
  36.         object_type = (char*)apr_table_get(resp_headers, OSS_OBJECT_TYPE);
  38.         printf("head object succeeded, object type:%s, content_length:%ld\n", 
  39.                object_type, content_length);
  40.     } else {
  41.         printf("head object failed\n");
  42.     }
  44.     aos_pool_destroy(p);
  45. }

注：

  • oss_head_object接口不会去下载文件内容，只会读取文件的元数据，包括系统级别和用户自定义的元数据
  • 完整代码参考：GitHub

拷贝文件

在同一个region中，用户可以对有操作权限的文件进行拷贝操作。以下代码通过oss_copy_object接口实现拷贝一个文件：

  1. aos_pool_t *p;
  2. oss_request_options_t *options;
  3. aos_status_t *s;
  4. aos_table_t * headers;
  5. aos_table_t *resp_headers;
  6. char *source_bucket_name = "<您的源bucket名字>";
  7. char *source_object_name = "<您的源object名字>";
  8. char *dest_bucket_name = "<您的目的bucket名字>";
  9. char *dest_object_name = "<您的目的object名字>";
  10. aos_string_t source_bucket;
  11. aos_string_t source_object;
  12. aos_string_t dest_bucket;
  13. aos_string_t dest_object;
  15. aos_pool_create(&p, NULL);
  17. options = oss_request_options_create(p);
  18. init_options(options);
  20. aos_str_set(&source_bucket, source_bucket_name);
  21. aos_str_set(&source_object, source_object_name);
  22. aos_str_set(&dest_bucket, dest_bucket_name);
  23. aos_str_set(&dest_object, dest_object_name);
  24. headers = aos_table_make(p, 0);
  26. /* 拷贝文件 */
  27. s = oss_copy_object(options, &source_bucket, &source_object, &dest_bucket, &dest_object, headers, &resp_headers);
  28. if (aos_status_is_ok(s)) {
  29.     printf("copy object succeeded\n");
  30. } else {
  31.     printf("copy object failed\n");
  32. }
  34. aos_pool_destroy(p);

注：

  • 需要注意的是源bucket与目的bucket必须属于同一region。
  • 如果拷贝文件超过1G，建议使用分片拷贝文件方式进行拷贝。

分片拷贝文件

当拷贝一个大于500MB的文件，建议通过oss_upload_part_copy接口来进行拷贝。以下代码实现分片拷贝一个文件

  1. aos_pool_t *p;
  2. oss_request_options_t *options;
  3. char *source_bucket_name = "<您的源bucket名字>";
  4. char *source_object_name = "<您的源object名字>";
  5. char *dest_bucket_name = "<您的目的bucket名字>";
  6. char *dest_object_name = "<您的目的object名字>";
  7. aos_string_t dest_bucket;
  8. aos_string_t dest_object;
  9. aos_string_t upload_id;
  10. aos_table_t *init_headers;
  11. aos_table_t *copy_headers;
  12. aos_table_t *list_part_resp_headers;
  13. aos_table_t *complete_resp_headers
  14. aos_table_t *resp_headers;
  15. aos_status_t *s;
  16. oss_list_upload_part_params_t *list_upload_part_params;
  17. oss_upload_part_copy_params_t *upload_part_copy_params1;
  18. aos_list_t complete_part_list;
  19. oss_list_part_content_t *part_content;
  20. oss_complete_part_content_t *complete_content;
  21. int part1 = 1;
  22. int64_t range_start1 = 0;
  23. int64_t range_end1 = 6000000;//not less than 5MB
  24. int max_ret = 1000;
  26. aos_pool_create(&p, NULL);
  28. options = oss_request_options_create(p);
  29. init_options(options);
  31. aos_str_set(&dest_bucket, dest_bucket_name);
  32. aos_str_set(&dest_object, dest_object_name);
  33. init_headers = aos_table_make(p, 0);
  34. s = oss_init_multipart_upload(options, &dest_bucket, &dest_object, init_headers, &upload_id, &resp_headers);
  36. /* 拷贝第一个分片数据  */
  37. upload_part_copy_params1 = oss_create_upload_part_copy_params(p);
  38. aos_str_set(&upload_part_copy_params1->source_bucket, source_bucket_name);
  39. aos_str_set(&upload_part_copy_params1->source_object, source_object_name);
  40. aos_str_set(&upload_part_copy_params1->dest_bucket, dest_bucket_name);
  41. aos_str_set(&upload_part_copy_params1->dest_object, dest_object_name);
  42. aos_str_set(&upload_part_copy_params1->upload_id, upload_id->data);
  43. upload_part_copy_params1->part_num = part1;
  44. upload_part_copy_params1->range_start = range_start1;
  45. upload_part_copy_params1->range_end = range_end1;
  46. copy_headers = aos_table_make(p, 0);
  47. s = oss_upload_part_copy(options, upload_part_copy_params1, copy_headers, &resp_headers);
  48. if (aos_status_is_ok(s)) {
  49.     printf("upload part copy succeeded\n");
  50. } else {
  51.     printf("upload part copy failed\n");
  52. }
  54. /* 继续拷贝剩余的分片，这里省略*/
  55. …
  57. /* 列出分片 */
  58. list_upload_part_params = oss_create_list_upload_part_params(p);
  59. list_upload_part_params->max_ret = max_ret;
  60. aos_list_init(&complete_part_list);
  61. s = oss_list_upload_part(options, &dest_bucket, &dest_object, &upload_id,
  62. list_upload_part_params, &list_part_resp_headers);
  63. aos_list_for_each_entry(part_content, &list_upload_part_params->part_list, node) {
  64.    complete_content = oss_create_complete_part_content(p);
  65.    aos_str_set(&complete_content->part_number, part_content->part_number.data);
  66.    aos_str_set(&complete_content->etag, part_content->etag.data);
  67.    aos_list_add_tail(&complete_content->node, &complete_part_list);
  68. }
  70. /* 完成分片拷贝 */
  71. s = oss_complete_multipart_upload(options, &dest_bucket, &dest_object, &upload_id, &complete_part_list, &complete_resp_headers);
  72. if (aos_status_is_ok(s)) {
  73.     printf("complete multipart upload succeeded\n");
  74. } else {
  75.     printf("complete multipart upload failed\n");
  76. }
  78. aos_pool_destroy(p);

删除文件

通过oss_delete_object接口，可以实现删除某个文件：

  1. void delete_object()
  2. {
  3.     aos_pool_t *p = NULL;
  4.     aos_string_t bucket;
  5.     aos_string_t object;
  6.     oss_request_options_t *options = NULL;
  7.     aos_table_t *resp_headers = NULL;
  8.     aos_status_t *s = NULL;
  10.     aos_pool_create(&p, NULL);
  12.     /* 创建并初始化options */
  13.     options = oss_request_options_create(p);
  14.     init_options(options);
  15.     aos_str_set(&bucket, "<您的bucket名字>");
  16.     aos_str_set(&object, "<您的object名字>");
  18.     /* 删除文件 */
  19.     s = oss_delete_object(options, &bucket, &object, &resp_headers);
  21.     /* 判断是否删除成功 */
  22.     if (aos_status_is_ok(s)) {
  23.         printf("delete object succeed\n");
  24.     } else {
  25.         printf("delete object failed\n");
  26.     }
  28.     /* 释放资源*/
  29.     aos_pool_destroy(p);
  30. }

注：

批量删除文件

通过oss_delete_objects接口，可以实现删除一批文件，用户可以通过is_quiet参数来指定是否返回删除的结果：

  1. aos_pool_t *p;
  2. aos_status_t *s;
  3. aos_table_t *resp_headers;
  4. oss_request_options_t *options;
  5. char *bucket_name = "<您的bucket名字>";
  6. char *object_name1 = "<您的object名字1>";
  7. char *object_name2 = "<您的object名字2>";
  8. aos_string_t bucket;
  9. aos_string_t object1;
  10. aos_string_t object2;
  11. oss_object_key_t *content1;
  12. oss_object_key_t *content2;
  13. aos_list_t object_list;
  14. aos_list_t deleted_object_list;
  15. int is_quiet = 1;
  17. options = oss_request_options_create(p);
  18. init_options(options);
  20. aos_str_set(&bucket, bucket_name);
  21. aos_str_set(&object1, object_name1);
  22. aos_str_set(&object2, object_name2);
  24. /* 构建待删除文件列表 */
  25. aos_list_init(&object_list);
  26. aos_list_init(&deleted_object_list);
  27. content1 = oss_create_oss_object_key(p);
  28. aos_str_set(&content1->key, object_name1);
  29. aos_list_add_tail(&content1->node, &object_list);
  30. content2 = oss_create_oss_object_key(p);
  31. aos_str_set(&content2->key, object_name2);
  32. aos_list_add_tail(&content2->node, &object_list);
  34. /* 删除多个文件 */
  35. s = oss_delete_objects(options, &bucket, &object_list, is_quiet, &resp_headers, &deleted_object_list);
  36. if (aos_status_is_ok(s)) {
  37.     printf("delete objects succeeded\n");
  38. } else {
  39.     printf("delete objects failed\n");
  40. }
  42. aos_pool_destroy(p);

批量删除指定前缀的文件

通过oss_delete_objects_by_prefix接口，可以实现删除一批指定前缀的文件：

  1. aos_pool_t *p;
  2. oss_request_options_t *options;
  3. aos_status_t *s;
  4. aos_table_t *resp_headers;
  5. char *bucket_name = "<您的bucket名字>";
  6. char *prefix_str = "<删除文件的前缀>";
  7. aos_string_t bucket;
  8. aos_string_t prefix;
  10. aos_pool_create(&p, NULL);
  12. options = oss_request_options_create(p);
  13. init_options(options);
  15. aos_str_set(&bucket, bucket_name);
  16. aos_str_set(&prefix, prefix_str);
  18. /* 删除满足特定前缀的文件*/
  19. s = oss_delete_objects_by_prefix(options, &bucket, &prefix);
  20. if (aos_status_is_ok(s)) {
  21.     printf("delete objects by prefix succeeded\n");
  22. } else {
  23.     printf("delete objects by prefix failed\n");
  24. }
  26. aos_pool_destroy(p);

注：

  • 批量删除指定前缀的文件可以实现删除目录的功能，比如删除dir目录，可以通过设置prefix的值为 dir/ 实现。
  • 如果设置prefix的值为空字符串(“”)或者NULL，将会删除整个bucket，请谨慎使用。
相关文档
相关产品
本文导读目录