• 自定义函数运行时
    • 协议约定
    • 配置约定
    • 启动约定

    自定义函数运行时

    函数运行时是函数执行的载体，通过加载函数代码来调用函数，跟函数实现的语言强相关。比如python代码需要使用python runtime来调用。这里就涉及到多种语言的问题，为了统一调用接口和协议，我们最终选择了GRPC，借助其强大的跨语言IDL和高性能RPC通讯能力，打造可灵活扩展的函数计算框架。

    协议约定

    GRPC的消息和服务定义如下，开发者可直接用于生成各自编程语言的消息和服务实现，GRPC使用方法可参考make pb命令，也可参考GRPC官网的文档。

    1. syntax = "proto3";
    3. package runtime;
    5. // The runtime definition.
    6. service Runtime {
    7.   // Handle handles request
    8.   rpc Handle (Message) returns (Message) {} // 消息处理接口
    9. }
    11. // The request message.
    12. message Message {
    13.   uint32 QOS                = 1; // MQTT消息的QOS
    14.   string Topic              = 2; // MQTT消息的主题
    15.   bytes  Payload            = 3; // MQTT消息的内容
    17.   string FunctionName       = 11; // 被调用的函数名
    18.   string FunctionInvokeID   = 12; // 函数调用ID
    19. }

    注意：Docker容器模式下，函数实例的资源限制不要低于50M内存，20个线程。

    配置约定

    函数配置的所有定义如下。对于自定义函数runtime，只需关注Function.Handler和Function.CodeDir的定义和使用，其他配置都是函数计算框架使用的配置。

    2. // Runtime runtime config
    3. type Runtime struct {
    4.     // 模块哦诶只
    5.     Module   `yaml:",inline" json:",inline"`
    6.     // 服务配置
    7.     Server   RuntimeServer `yaml:"server" json:"server"`
    8.     //
    9.     Function Function      `yaml:"function" json:"function"`
    10. }
    12. // RuntimeServer function runtime server config
    13. type RuntimeServer struct {
    14.     Address string        `yaml:"address" json:"address" validate:"nonzero"`
    15.     Timeout time.Duration `yaml:"timeout" json:"timeout" default:"30s"`
    16.     Message struct {
    17.         Length Length `yaml:"length" json:"length" default:"{\"max\":4194304}"`
    18.     } `yaml:"message" json:"message"`
    19. }
    21. // Function function config
    22. type Function struct {
    23.     // 函数ID，目前用于映射函数代码所在的目录
    24.     ID      string `yaml:"id" json:"id" validate:"regexp=^[a-zA-Z0-9_-]{1\\,140}$"`
    25.     // 函数名，函数调用使用的名称
    26.     Name    string `yaml:"name" json:"name" validate:"regexp=^[a-zA-Z0-9_-]{1\\,140}$"`
    27.     // 函数执行的入口
    28.     Handler string `yaml:"handler" json:"handler" validate:"nonzero"`
    29.     // 函数代码所在目录
    30.     CodeDir string `yaml:"codedir" json:"codedir"`
    31.     // 实例配置
    32.     Instance Instance          `yaml:"instance" json:"instance"`
    33.     // 函数runtime，docker容器模式下是函数runtime的镜像，native进程模式下是函数runtime的可执行程序路径
    34.     Entry    string            `yaml:"entry" json:"entry"`
    35.     // 函数runtime启动进程时传入的环境变量
    36.     Env      map[string]string `yaml:"env" json:"env"`
    37. }
    39. // Instance instance config for function runtime module
    40. type Instance struct {
    41.     // 最少实例数
    42.     Min       int           `yaml:"min" json:"min" default:"0" validate:"min=0, max=100"`
    43.     // 最多实例数
    44.     Max       int           `yaml:"max" json:"max" default:"1" validate:"min=1, max=100"`
    45.     // 实例最大空闲时间
    46.     IdleTime  time.Duration `yaml:"idletime" json:"idletime" default:"10m"`
    47.     // 实例调用超时时间
    48.     Timeout   time.Duration `yaml:"timeout" json:"timeout" default:"5m"`
    49.     // 实例的资源配置
    50.     Resources Resources     `yaml:",inline"  json:",inline"`
    51.     // 消息最大长度限制
    52.     Message   struct {
    53.         Length Length `yaml:"length" json:"length" default:"{\"max\":4194304}"`
    54.     } `yaml:"message" json:"message"`
    55. }

    启动约定

    函数runtime实际上也是一种模块，只是比较特殊，是被函数计算模块在运行过程中按需启动的模块，归为临时模块。其启动方式和普通模块启动的方式基本一致，只不过临时模块没有固定路径，不支持从配置文件中加载配置。因此约定通过传参的方式传入配置信息，使用JSON格式，比如-c "{\"name\":\"sayhi\", …}"。

    函数runtime启动并加载配置后，首先根据Server配置初始化GRPC server，然后根据Function的配置加载函数代码入口，等待函数计算模块来调用，最后注意监听SIGTERM信号来优雅退出。完整的实现过程可参考python27 runtime。

    最后更新于 2018-12-28 10:23:09

    原文: https://openedge.tech/docs/customize/How-to-develop-a-customize-runtime-for-function