微信云托管教程(116)：对象存储-COS-SDK服务端使用（三） ,重庆网站建设,重庆网站开发,重庆网络营销,重庆APP制作培训,重庆互联网

微信云托管教程(116)：对象存储-COS-SDK服务端使用（三）

作者：重庆互联网小徐发布时间：2024-03-15 浏览：20772 赞（1950）收藏评论（0）

三、文件元数据

在服务端上传文件时，需要对文件增加元数据，以区分上传者 OpenID 和控制文件权限。若文件无元数据，则该文件将不可被小程序侧访问。

通过如下的接口，可以获取文件元数据，或对元数据进行解析得到 OpenID。

1. 获取元数据

输入用户openid，bucket名称和上传目录，获取文件的加密元数据。

POST https://api.weixin.qq.com/_/cos/metaid/encode

body信息：

{
  "openid": "exampleopenid",
  "bucket": "bucket", // 在「微信云托管控制台-对象存储-存储配置」获取
  "paths": [
    "/aaa", // 文件路径
    "/bbb"
  ]}

返回结果如下，返回的 x_cos_meta_field_strs 的顺序与输入的顺序相同。

{
  "errcode": 0,
  "errmsg": "ok",
  "respdata": {
    "x_cos_meta_field_strs": [
      "xxx-xxx-xxxxxx",
      "xxx-xxx-xxxxxx"
    ]
  }}

接口 /_/cos/metaid/encode，理论上可以生成任意存在或者不存在的文件、存储桶、openid为入参的元数据，本质上是对这些入参做了一次签名，在之后的客户端（小程序/h5）使用时，可以根据元数据推断出所属用户，并根据权限管理的设定做出读写拦截或放通。

所以你可以根据业务的自身情况，灵活的使用元数据达到期待效果。比如预先生成，重写文件的元数据改变所属人等。如果你生成的元数据跟真实的不符，无法解析或者信息不对应，统一按照未知处理；若权限在创建者可读写的情况下，只有管理端（SDK或者服务端API）可以对文件进行修改，小程序端无法操作读写。

2. 解析元数据

输入加密元数据，返回用户openid，上传目录和bucket名称。暂仅支持解析单个 metaid，批量解析时需要注意访问频率。

POST https://api.weixin.qq.com/_/cos/metaid/decode

{
  "metaid": "xxx-xxx-xxxxxx"}

返回结果

{
  "errcode": 0,
  "errmsg": "ok",
  "respdata": {
    "raw_data": {
      "openid": "exampleopenid",
      "bucket": "bucket",
      "appid": "exampleappid",
      "path": "/aaa",
      "mpAppId": "exampleappid"
    },
    "x_cos_meta_field_strs": []
  }}

3. 使用元数据上传文件

以 NodeJS SDK 为例，需要在文件的 Headers 中增加 x-cos-meta-fileid

以下是封装的上传文件方法，可参考后自行调整：

const fs = require('fs')const cosConfig = {
  Bucket: '', // 填写云托管对象存储桶名称
  Region: 'ap-shanghai' // 存储桶地域，默认是上海，其他地域环境对应填写}/**
 * 封装的上传文件函数
 * @param {*} cloudpath 上传的云上路径
 * @param {*} filepath 本地文件路径
 */async function uploadFile (cloudpath, filepath) {
  const authres = await call({
    url: 'http://api.weixin.qq.com/_/cos/metaid/encode',
    method: 'POST',
    data: {
      openid: '', // 填写用户openid，管理端为空字符串
      bucket: cosConfig.Bucket,
      paths: [cloudpath]
    }
  })
  try {
    const auth = JSON.parse(authres)
    const res = await this.cos.putObject({
      Bucket: cosConfig.Bucket,
      Region: cosConfig.Region,
      Key: cloudpath,
      StorageClass: 'STANDARD',
      Body: fs.createReadStream(filepath),
      ContentLength: fs.statSync(filepath).size,
      Headers: {
        'x-cos-meta-fileid': auth.respdata.x_cos_meta_field_strs[0]
      }
    })
    if (res.statusCode === 200) {
      return {
        code: 0,
        file: JSON.stringify(res)
      }
    } else {
      return {
        code: 1,
        msg: JSON.stringify(res)
      }
    }
  } catch (e) {
    console.log('上传文件失败', e.toString())
    return {
      code: -1,
      msg: e.toString()
    }
  }}function call (obj) {
  return new Promise((resolve, reject) => {
    request({
      url: obj.url,
      method: obj.method || 'POST',
      headers: {
        'content-type': 'application/json'
      },
      body: JSON.stringify(obj.data || {})
    }, function (err, response) {
      if (err) reject(err)
      resolve(response.body)
    })
  })}