集成小米FDS

当您在小米FDS上创建或删除了某个对象时，函数计算能够根据您创建的FDSTrigger自动检测到发生的事件，同时触发相关函数的执行。

目前函数计算同时支持新版及旧版FDS，在运行环境Python2及Python3中均可以使用。

如果您想要为上传到FDS中指定bucket的图像创建一个缩略图，可以参考如下代码：

  1. from fds import GalaxyFDSClient,GalaxyFDSClientException,FDSClientConfiguration 
  2. import os,sys
  3. from PIL import Image
  5. before_file = DOWNLOAD_IMAGE_FROM_FDS
  6. after_file = UPLOAD_THUMBNAIL_TO_FDS
  8. class FDSConfig:
  9.     def __init__(self, AK, SK, ENDPOINT):
  10.         self.AK = AK
  11.         self.SK = SK
  12.         self.ENDPOINT = ENDPOINT
  14. def get_client():
  15.     fds_config = _get_FDSConfig()
  16.     config = FDSClientConfiguration()
  17.     if fds_config.ENDPOINT == None:
  18.         print "endpoint is None, please check env $XIAOMI_FDS_ENDPOINT"
  19.         return
  20.     config.set_endpoint(fds_config.ENDPOINT)
  21.     return GalaxyFDSClient(fds_config.AK, fds_config.SK,config)
  23. def _get_FDSConfig():
  24.     AK = os.environ.get("AK")
  25.     SK = os.environ.get("SK")
  26.     ENDPOINT = os.environ.get("XIAOMI_FDS_ENDPOINT")
  27.     return FDSConfig(AK, SK, ENDPOINT)
  29. def get_image_from_fds(client,bucket):
  30.     file = open(before_file, "w+")
  31.     try:
  32.         image_object = client.get_object(bucket,object)
  33.         for chunk in image_object.stream:
  34.             file.write(chunk)
  35.     except GalaxyFDSClientException as e:
  36.         print e.message
  37.     finally:
  38.         file.close()
  40. def save_thumbnail():
  41.     im = Image.open(before_file)
  42.     size = (70,15)
  43.     im.thumbnail(size)
  44.     im.save(after_file,"png")
  45.     im.close()
  47. def put_image_to_fds(client,bucket):
  48.     object_name = after_file.split("/")[-1]
  49.     image = open(after_file)
  50.     client.put_object(bucket,object_name,image)
  51.     return object_name
  53. def main(event):
  54.     bucket = event['bucketName']
  55.     object = event['objectName']
  56.     print "start function"
  57.     client = get_client()
  58.     if not client.does_bucket_exist(bucket) :
  59.         print "bucket [%s] not exist ,please create first" %bucket
  60.         return False
  61.     get_image_from_fds(client,bucket)
  62.     save_thumbnail()
  63.     after_object_name = put_image_to_fds(client,bucket)
  64.     if client.does_object_exists(bucket, after_object_name):
  65.         print "thunmbnail has uploaded to FDS , object is [%s]" %after_object_name
  66.         return True
  67.     return False

在您使用这个函数时，请参考下图设置环境变量AK，SK及XIAOMI_FDS_ENDPOINT，示例代码是通过这三个环境变量，调用FDS的sdk，完成获取及上传图片的功能，同时请修改代码中“before_file”，“after_file”这两个变量。

请注意AK/SK两个参数，如果您使用老版FDS，需要由dev.mi.com的密钥中心获取AK/SK,如果您使用新版FDS，请从用户管理中获取AK/SKAlt textevent参数为dict类型，内容如下，请根据您的需求进行编码，其中action字段有两种取值：“PutObject”，“DeleteObject”：

  1. {
  2.      "bucketName":"test-fds",
  3.      "objectName":"image.png",
  4.      "action":"ACTION",
  5.      "uuid":"3535a4ce-010b-42f2-bce9-ffb46d421aa5",
  6.      "timestamp":1506305123069,
  7.      "versionId":"12345"
  8.  }

原文: http://docs.api.xiaomi.com/faas/应用示例/section3.html