阿里云函数计算为了降低开发者使用难度，推出了大量实用的模板供给用户使用，每个模板都提供一段业务示例逻辑代码，能降低用户使用门槛。下面来详细讲解基于对象存储的几个常用模板的使用方法和内容，更多模板详见！
引用步骤，进入函数计算控制台后，选择新建函数，在搜索框里填写OSS会自动检索出跟OSS相关的模板，目前系统内置了8个跟OSS相关的模板。
关于函数计算和OSS操作的模板，目前系统内置提供了8个模板，分别解决的问题有：把OSS数据同步备份到其他地方、获取对象的meta信息，获取OSS文件的MD5值、爬虫系统、图像识别、对OSS上的文件打包压缩、以及获取对象的详细信息等。今天讲解其中3个常用业务模板。
模板概述
阿里云函数计算模板主要包含三部分内容，模板详情描述、模板引用资源授权（部分不使用其他产品资源不需要授权）、模板示例代码。操作流程如下：
新建函数-》引用模板创建-》给模板引用的资源授权（选填，有些模板不需要引用外置的资源）-》获取代码示例。
模板一：get-oss-md5-python27（获取对象存储文件的MD5值）
通过该模板的示例代码，可以计算出对象存储（OSS）文件的MD5值，本示例的代码通过流式方式读取对象文件，计算的效率较高。基于数据访问安全考虑，需要授权某bucket给函数计算来使用，通过函数计算的引导页面可以完成。
模板详情：通过模板详情可以获取到模板的详细情况，例如输入参数，输出参数等。详细引用查看这里。模板详情里会包括示例说明，输入参数，输出参数，以及需要哪些授权等，下面的模板同。
附录几张界面截图：
模板授权：基于数据访问安全考虑，需要授权某bucket给函数计算来使用。
授权页面设置，本示例只需要选择某个Bucket授权即可。
代码详解：采用流式方式来读取文件的MD5值，其中creds = context.credentials是获取系统生成的临时AK来作为执行的认证。
# coding=utf-8
import json
import logging
from hashlib import md5
import oss2
# 函数服务主函数
def handler(event, context):
logger = logging.getLogger()
logger.info('start worker')
evt = json.loads(event)
endpoint = 'oss-{}-internal.aliyuncs.com'.format(context.region)
creds = context.credentials #获取系统生成的临时AK
auth = oss2.StsAuth(creds.access_key_id, creds.access_key_secret, creds.security_token)
bucket_name = evt['bucket']
bucket = oss2.Bucket(auth, endpoint, bucket_name)
object_name = evt['object']
r = bucket.get_object(object_name)
m = md5()
while 1:
data = r.read(4096)
if not data:
break
m.update(data)
return m.hexdigest()
模板二：copy-oss-object-python27（同步备份OSS增量数据）
通过该模板的示例代码，可以把指定某个Bucket下的文件备份到其他资源，示例代码是备份到七牛存储上，也可以修改示例代码，把文件存储到本地硬盘或者某个服务上。对于大文件同步本示例文档对大文件备份做了优化，授权方式跟模板一介绍的一致，需要授权使用。
# -*- coding: utf-8 -*-
from qiniu import Auth, put_file, etag, urlsafe_base64_encode
import qiniu.config
import oss2
import json
def handler(event, context):
"""
Replicate the object from OSS to qiniu.
event: The OSS event json string. Including oss object uri and other information.
context: The function context, including credential and runtime info.
For detail info, please refer to https://help.aliyun.com/document_detail/56316.html#using-context
"""
evt_list = json.loads(event)
creds = context.credentials
auth = oss2.StsAuth(creds.access_key_id, creds.access_key_secret, creds.security_token)
# Parse the event to get the source object info.
evt = evt_list['events'][0]
bucket_name = evt['oss']['bucket']['name']
endpoint = 'oss-' + evt['region'] + '.aliyuncs.com'
bucket = oss2.Bucket(auth, endpoint, bucket_name)
object_name = evt['oss']['object']['key']
# Download the oss object.
remote_stream = bucket.get_object(object_name)
if not remote_stream:
raise RuntimeError('failed to get oss object. bucket: %s. object: %s' % (bucket_name, object_name))
print 'download object from oss success: %s' % object_name
# replicate to qiniu
qiniu_ak_id = 'XXXX'
qiniu_ak_secret = 'XXXX'
qiniu_bucket_name = 'XXX'
q = Auth(qiniu_ak_id, qiniu_ak_secret)
qiniu_token = q.upload_token(qiniu_bucket_name, object_name, 1200)
ret, info = qiniu.put_data(qiniu_token, object_name, remote_stream)
if ret is None:
print info
else:
print 'replicate to qiniu success: %s' % object_name
# TODO: Verify the checksum
# TODO: Handle the error模板三：oss-download-zip-upload（下载OSS对象并打压缩包）
通过该模板示例，您可以完成从OSS某个Bucket中下载图片，对图片进行打包（ZIP），并把打包后的ZIP文件上传到某Bucket中操作。注意该函数对应的Service的角色访问策略需要读写OSS的权限。
import os
import oss2
import zipfile
import shutil
import time
def handler(event, context):
creds = context.credentials
auth = oss2.StsAuth(creds.accessKeyId, creds.accessKeySecret, creds.securityToken)
bucket = oss2.Bucket(auth, 'your endpoint', 'your buecket name')
#your source list
sourceFile = ['resource/1.jpg','resource/2.jpg']
#zip name
uid = 'ZIP123456'
tmpdir = '/tmp/download/'
os.system("rm -rf /tmp/*")
os.mkdir(tmpdir)
#download
for name in sourceFile :
millis = int(round(time.time() * 1000))
bucket.get_object_to_file(name , tmpdir + str(millis) + '.jpg')
#zip file
zipname = '/tmp/'+uid + '.zip'
make_zip(tmpdir , zipname)
#upload
total_size = os.path.getsize(zipname)
part_size = oss2.determine_part_size(total_size, preferred_size = 128 * 1024)
key = uid + '.zip'
upload_id = bucket.init_multipart_upload(key).upload_id
with open(zipname, 'rb') as fileobj:
parts = []
part_number = 1
offset = 0
while offset < total_size:
num_to_upload = min(part_size, total_size - offset)
result = bucket.upload_part(key, upload_id, part_number,oss2.SizedFileAdapter(fileobj, num_to_upload))
parts.append(oss2.models.PartInfo(part_number, result.etag))
offset += num_to_upload
part_number += 1
bucket.complete_multipart_upload(key, upload_id, parts)
return total_size
def make_zip(source_dir, output_filename):
zipf = zipfile.ZipFile(output_filename, 'w')
pre_len = len(os.path.dirname(source_dir))
for parent, dirnames, filenames in os.walk(source_dir):
for filename in filenames:
pathfile = os.path.join(parent, filename)
arcname = pathfile[pre_len:].strip(os.path.sep)
zipf.write(pathfile, arcname)
zipf.close()
