花市小说网站那里进,网站主题包括,域名网站平台,花里胡哨的网站摘要#xff1a; Serverless 是一种架构理念#xff0c;具有自己的独特的优势和适用场景。本文以使用阿里云函数计算为例#xff0c;构建一个简单具体的microservice为例#xff0c;看看这种架构是如何达到快速开发和节约运维成本的。
点此查看原文#xff1a;http://clic…摘要 Serverless 是一种架构理念具有自己的独特的优势和适用场景。本文以使用阿里云函数计算为例构建一个简单具体的microservice为例看看这种架构是如何达到快速开发和节约运维成本的。
点此查看原文http://click.aliyun.com/m/41322/
Serverless 是一种架构理念具有自己的独特的优势和适用场景。本文以使用阿里云函数计算为例构建一个简单具体的microservice为例看看这种架构是如何达到快速开发和节约运维成本的。
应用场景1
某游戏公司刚开发完一个新的游戏想要进行一些封闭测试他们需要一个管理激活码的service来邀请有激活码的玩家来参与封闭测试同时可能对积极参与封闭测试的玩家等正式开服后给予一定的礼包券码
应用场景2
某垂直领域的电商刚刚起步流量不是特别大但发展势头不错。他们需要一个管理优惠码的service
针对上面所说的两个场景无论是优惠码激活码等相关码的管理一般有如下四个
生成码 使用码 验证码 删除码
传统方案
用户自己去架设服务器配置数据库再编写对应的服务再配备相应的运维人员总之不管是硬件成本还是人力成本都不少。
serverless 方案 在本文中我们运用阿里云API Gateway 函数计算 表格存储(OTS)就能快速搭建这个服务API Gateway 会自动 scale 去应对请求流量同样函数计算也会根据流量自动 scale。开发方面只需要实现好对应的逻辑函数即可。运维方面省去了管理密匙、打安全补丁等工作因为用户根本没有需要维护的机器。整个解决方案如下图从上图我们可以看出主要有两个步骤
函数计算作为 API 网关后端服务, 具体的教程可以参考官方教程和函数计算获取临时token 函数计算结合ots实现具体的逻辑本文主要讲解这个过程, 并给出具体的代码。
具体步骤
1, 创建一个ots实例并在实例中创建一张表在本例中是在华东2 region创建了code-ots实例并在该实例中创建了一张表code, 主键是STRING类型2, 创建对应的serviceservice下面创建4个函数分别为gen_code, del_code, query_code, use_code, 具体的代码可以在本文最后附件下载由于函数要访问ots这边需要配置service可以读写ots的权限相关授权教程可以参考函数计算实现流式处理大文件中的具体步骤第2步, 本文最后配置如下图从下图可知我们创建的service的服务角色是fc-ots-rw,该角色拥有对ots读写的权限。具体function
1 生成码 配置event
{num:1000,start period:2017-12-22 00:00:00,end period:2017-12-28 00:00:00,
}
通过这个配置的event设置的目标是产生1000个码 码的有效期在2017-12-22 00:00:00 至 2017-12-28 00:00:00默认产生的状态都是UNACTIVED未激活的
code
# -*- coding: utf-8 -*-
import uuid
import json
import time
from tablestore import *
from tablestore.retry import WriteRetryPolicytable_name code # 具体的table
ots_name code-ots # ots 实例
BATCH_NUM 200def batch_write_row(client, start, end, num):put_row_items []for i in range(0, num):uid_str str(uuid.uuid1())primary_key [(uuid, uid_str)]attribute_columns [(start, start), (end, end), (status, UNACTIVED)]row Row(primary_key, attribute_columns)condition Condition(RowExistenceExpectation.EXPECT_NOT_EXIST)item PutRowItem(row, condition)put_row_items.append(item)request BatchWriteRowRequest()request.add(TableInBatchWriteRowItem(table_name, put_row_items))result client.batch_write_row(request)succ, fail result.get_put()print (check input table\s put results: is_all_succeed{0}; succ_num{1}; \fail_um{2}.format(result.is_all_succeed(), len(succ), len(fail)))for item in fail:print (Put failed, error code: %s, error message: %s % (item.error_code, item.error_message))def upload_ots(context, num, start, end):endpoint https://{}.cn-shanghai.ots-internal.aliyuncs.com.format(ots_name)creds context.credentialsclient OTSClient(endpoint, creds.accessKeyId, creds.accessKeySecret, ots_name, sts_token creds.securityToken, retry_policy WriteRetryPolicy())while num 0:w_num numif num BATCH_NUM:w_num BATCH_NUMbatch_write_row(client, start, end, w_num)num num - w_numdef handler(event, context):evt json.loads(event)num int(evt[num])start evt[start period]end evt[end period]start_t time.mktime(time.strptime(start, %Y-%m-%d %H:%M:%S))end_t time.mktime(time.strptime(end, %Y-%m-%d %H:%M:%S))print uuid.uuid1(), type(uuid.uuid1())upload_ots(context, num, start_t, end_t)return ok
2 使用码
配置event
{uuid:254804e8-e707-11e7-9c21-0242ac110004
}
假设使用码254804e8-e707-11e7-9c21-0242ac110004只有表中存在这个码并且这个码是UNACTIVED才返回SUCCESS并且把该码的状态设置为ACTIVED。其他情况比如不存在这个码或者是存在这个码但是已经被激活使用过都返回FAIL
code
# -*- coding: utf-8 -*-
from tablestore import *
from tablestore.retry import WriteRetryPolicy
import jsontable_name code
ots_name code-otsdef update_row(client, uuid):primary_key [(uuid,uuid)]update_of_attribute_columns {PUT : [(status,ACTIVED)],}row Row(primary_key, update_of_attribute_columns)condition Condition(RowExistenceExpectation.EXPECT_EXIST, SingleColumnCondition(status, UNACTIVED, ComparatorType.EQUAL)) try:consumed, return_row client.update_row(table_name, row, condition) print (Update succeed, consume %s write cu. % consumed.write)except Exception as e:return FAILEDreturn SUCCEEDdef handler(event, context):endpoint https://{}.cn-shanghai.ots-internal.aliyuncs.com.format(ots_name)creds context.credentialsclient OTSClient(endpoint, creds.accessKeyId, creds.accessKeySecret, ots_name, sts_token creds.securityToken, retry_policy WriteRetryPolicy())evt json.loads(event)uuid str(evt[uuid])return update_row(client, uuid)
3 查询码
配置event
{uuid:254804e8-e707-11e7-9c21-0242ac110004
}
假设查询码254804e8-e707-11e7-9c21-0242ac110004只有表中不存在这个码返回NO EXISTED, 存在的话则返回表中记录的状态
code
# -*- coding: utf-8 -*-
from tablestore import *
from tablestore.retry import WriteRetryPolicy
import time,jsontable_name code
ots_name code-otsdef get_row(client, uuid):primary_key [(uuid, uuid)]columns_to_get []cond CompositeColumnCondition(LogicalOperator.OR)cond.add_sub_condition(SingleColumnCondition(status, UNACTIVED, ComparatorType.NOT_EQUAL))cond.add_sub_condition(SingleColumnCondition(status, UNACTIVED, ComparatorType.EQUAL))consumed, return_row, next_token client.get_row(table_name, primary_key, columns_to_get, cond, 1)print (Read succeed, consume %s read cu. % consumed.read)if return_row is None:return NO EXISTEDstatus UNKNOWNfor att in return_row.attribute_columns:print (name:%s\tvalue:%s\ttimestamp:%d % (att[0], att[1], att[2]))if att[0] status:status att[1]if att[0] start:start att[1]if att[0] end:end att[1]current_time time.time()if current_time end or current_time start:status TIMEINVALIDreturn status def handler(event, context):endpoint https://{}.cn-shanghai.ots-internal.aliyuncs.com.format(ots_name)creds context.credentialsclient OTSClient(endpoint, creds.accessKeyId, creds.accessKeySecret, ots_name, sts_token creds.securityToken, retry_policy WriteRetryPolicy())evt json.loads(event)uuid str(evt[uuid])return get_row(client, uuid)
4 删除码
配置event
{uuid:254804e8-e707-11e7-9c21-0242ac110004
}
假设删除码254804e8-e707-11e7-9c21-0242ac110004不管表中是否存在这个码只要表中没有这个码了就是成功删除除非ots sdk delete_row抛出异常
code
# -*- coding: utf-8 -*-
from tablestore import *
from tablestore.retry import WriteRetryPolicy
import jsontable_name code
ots_name code-otsdef delete_row(client, uuid):primary_key [(uuid,uuid)]row Row(primary_key)condition Condition(RowExistenceExpectation.IGNORE, SingleColumnCondition(status, , ComparatorType.NOT_EQUAL))try:consumed, return_row client.delete_row(table_name, row, condition) print (Delete succeed, consume %s write cu. % consumed.write)except:return FAILEDreturn SUCCEEDdef handler(event, context):endpoint https://{}.cn-shanghai.ots-internal.aliyuncs.com.format(ots_name)creds context.credentialsclient OTSClient(endpoint, creds.accessKeyId, creds.accessKeySecret, ots_name, sts_token creds.securityToken, retry_policy WriteRetryPolicy())evt json.loads(event)uuid str(evt[uuid])return delete_row(client, uuid)
