开发者社区> 4hyf.com> 正文
阿里云
为了无法计算的价值
打开APP
阿里云APP内打开

函数计算配置中心

简介: 由于多个函数计算中都会执行数据库操作,而一旦数据库更改则需要修改全部函数计算。所以将数据库配置存入OSS中以便统一进行管理。
+关注继续查看

一. 新建OSS配置文件存储仓库

1. 进入OSS控制台,新建bucket【fc-config】

新建bucket

2. 创建一个子账户,用于读取OSS上的文件

  • 进入【RAM访问控制】-【用户】-【新建用户】
    新建用户
  • 为子账户分配权限
    分配权限
  • 为子账户创建AccessKey
    创建AccessKey

3. 编写测试文件

在本地创建一个【fc-test-config.json】文件,写入一些测试内容:

{
    "host": "127.0.0.1",
    "port": 3306,
    "username": "test",
    "password": "123456"
}

4. 上传测试文件

上传测试文件

二、编写配置中心代码

1. 使用模板生成

fun init -n fc-config https://github.com/l616769490/python3-http-example.git

使用模板生成

2. 编写代码

import json
import oss2

def handler(environ, start_response):
    # 获取请求体
    try:
        request_body_size = int(environ.get('CONTENT_LENGTH', 0))
    except (ValueError):
        request_body_size = 0

    request_body = environ['wsgi.input'].read(request_body_size)

    status, response = getConfigByName(str(request_body, encoding = "utf-8"))

    response_headers = [('Content-type', 'application/json')]
    start_response(status, response_headers)

    # 返回数据
    return [json.dumps(response).encode()]

def getConfigByName(fileName):
    utils = OSSUtils('这里替换成你的AccessKeyId', '这里替换成你的AccessKeySecret')
    return utils.getConfigByName(fileName, 'fc-config')

_ENDPOINT = 'https://oss-cn-shanghai.aliyuncs.com'

class OSSUtils:
    """ 封装OSS中的常用操作
    """

    def __init__(self, accessKeyId, accessKeySecret):
        """ 
        :param accessKeyId 阿里云accessKeyId
        :param accessKeySecret 阿里云accessKeySecret
        """
        self.accessKeyId = accessKeyId
        self.accessKeySecret = accessKeySecret
    
    def getConfigList(self, bucketName, dirName = ''):
        """ 获取配置列表 
        :param bucketName bucket名
        :param dirName 文件夹名
        """
        auth=oss2.Auth(self.accessKeyId, self.accessKeySecret)
        bucket = oss2.Bucket(auth, _ENDPOINT, bucketName)

        files = []
        for obj in oss2.ObjectIterator(bucket, dirName, ''):
            if obj.key != dirName:
                files.append(obj.key)
        return '200', files
    
    def getConfigByName(self, fileName, bucketName, dirName = ''):
        """ 获取配置
        :param fileName:配置文件名
        :param bucketName bucket名
        :param dirName 文件夹名
        :return: status, data status:成功返回200,失败返回404; data:成功返回数据,失败返回错误信息
        """
        auth=oss2.Auth(self.accessKeyId, self.accessKeySecret)
        bucket = oss2.Bucket(auth, _ENDPOINT, bucketName)

        objectName = dirName + fileName

        status = '200'
        data = ''
        try:
            remote_stream = bucket.get_object(objectName)
            data = str(remote_stream.read(), encoding = 'utf-8')
        except Exception as err:
            return err.status, err.message

        return status, data
    
    def updateConfig(self, data, bucketName, dirName = ''):
        """ 修改或者新增配置文件
        :param data{fileName, data}: fileName:文件名; data:文件内容
        :param bucketName bucket名
        :param dirName 文件夹名
        :return: status, data status:成功返回200,失败返回500; data:成功返回数据,失败返回错误信息
        """
        status = '200'
        data = ''
        if (data == None):
            data = '新增或修改失败'
            return status, data
        
        fileName = data['fileName']
        configData = data['data']

        try:
            auth=oss2.Auth(self.accessKeyId, self.accessKeySecret)
            bucket = oss2.Bucket(auth, _ENDPOINT, bucketName)
            objectName = dirName + fileName
            bucket.put_object(objectName, configData)

            data = '操作成功'
        except Exception as err:
            return err.status, err.message

        return status, data

三、测试

测试截图

四、其他函数计算中调用

1. 新建一个无触发器的普通函数计算【fc-config-test】,代码如下:

# -*- coding: utf-8 -*-
import requests
import datetime
import json

_HEADER = {
        'Content-Type' : 'application/json; charset=utf-8',
        'Date' : (datetime.datetime.now()-datetime.timedelta(hours=8)).strftime("%a, %d %b %Y %H:%M:%S GMT") 
    }

_CONF_HOST = '修改为你的配置中心地址'

def getDataForStr(host, data):
    """ 获取配置文件
    :param data:请求内容,字符串
    """
    r = requests.post(host, headers = _HEADER, data = data.encode())
    return r

def handler(event, context):
  conf = json.loads(getDataForStr(_CONF_HOST, 'fc-test-config.json').text)
  return conf

2. 执行

执行结果

版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。

相关文章
通过 Serverless Devs 快速创建函数计算应用(一)
通过 Serverless Devs 快速创建函数计算应用(一)
171 0
基于Serverless Devs原子化操作阿里云函数计算
众所周知,随着时间的发展,Serverless命令行工具也逐渐的玩出了更多的花样,就目前来看,常见的形态有两种,一种是通过Yaml来进行资源的描述
317 0
零基础入门Serverless:Todo List应用创建(体验函数计算抽盲盒,1500等领)
今年天猫双十一,阿里云Serverless支撑业务场景更多,范围更广。越来越多企业和开发者正在尝试使用Serverless,而Serverless开发者工具无疑是加速Serverless快速落地的利器。 这一次,我们基于阿里云函数计算+Serverless开发者工具Serverless Devs打造场景,让你用“一行代码” 极速进入Serverless的世界。
157 0
独家对话阿里云函数计算负责人不瞋:你所不知道的 Serverless
如果你是一名互联网研发人员,那么极有可能了解并应用过 Serverless 这套技术体系。纵观 Serverless 过去十年,它其实因云而生,也在同时改变云的计算方式。如果套用技术成熟度曲线来描述的话,那么它已经走过了萌芽期、认知破灭期,开始朝着成熟稳定的方向发展。未来,市场对 Serverless 的接受程度将越来越高。
3597 0
独家对话阿里云函数计算负责人不瞋:你所不知道的 Serverless
日前,阿里云凭借函数计算产品能力全球第一的优势,入选 Forrester 2021 年第一季度 FaaS 平台评估报告,成为比肩亚马逊、全球前三的 FaaS 领导者。这也是首次有国内科技公司进入 FaaS 领导者象限。不瞋作为阿里云 Serverless 产品体系的负责人,也是国内 Serverless 的早期实践者。本文将呈现这次访谈的完整总结。
1332 0
触摸云端编程之道——基于函数计算的serverless应用开发
本文的整理自2017云栖大会-南京峰会上阿里云存储服务高级专家杨皓然的分享讲义,讲义主要介绍了基于函数计算的serverless应用开发的相关内容,从计算的新需求和计算的演化过程谈起,对比传统计算所面临的困境介绍了函数计算所具有的优势,并介绍了函数计算的使用流程和应用示例。
2206 0
流计算
在过去几年里,已为流计算开发了数百项应用。下面简单介绍了一些应用,着重强调了流计算支持的使用类型。面对日益增长的海量数据,精细化营销的挑战.通常电信行业会面临海量数据,异构数据,实时主动分析等挑战.
276 0
+关注
3
文章
0
问答
文章排行榜
最热
最新
相关电子书
更多
低代码开发师(初级)实战教程
立即下载
阿里巴巴DevOps 最佳实践手册
立即下载
冬季实战营第三期:MySQL数据库进阶实战
立即下载