go函数开发概述-j9九游会登录

go函数接口定义

functiongraph运行时支持go 1.x版本，函数有明确的接口定义，如下所示：

func handler (payload []byte, ctx context.runtimecontext)

• 入口函数名（handler）：入口函数名称。
• 执行事件体（payload）： 函数执行界面由用户输入的执行事件参数， 格式为json对象。
• 上下文环境（ctx）：runtime提供的函数执行上下文，其接口定义在sdk接口说明。

go函数的函数执行入口参数格式为：与代码包中的可执行文件名保持一致。编译后的动态库文件名称必须与函数执行入口的插件名称保持一致，例如：动态库名称为testplugin.so，则函数执行入口命名为testplugin.handler。可通过functiongraph控制台进入函数详情页的常规设置中进行配置或修改。

sdk接口

functiongraph函数gosdk提供了event事件接口、context接口和日志记录接口。（）。

• event事件接口

  go sdk加入了触发器事件结构体定义，目前支持cts、kafka、dis、dds、smn、lts、timer、apig、触发器。在需要使用触发器的场景时，编写相关代码更简单。

  1. apig触发器相关字段说明
     1. apigtriggerevent相关字段说明

        表1 apigtriggerevent相关字段说明

        字段名	字段描述
        isbase64encoded	event中的body是否是base64编码
        httpmethod	http请求方法
        path	http请求路径
        body	http请求body
        pathparameters	所有路径参数
        requestcontext	相关的apig配置（apigrequestcontext对象）
        headers	http请求头
        querystringparameters	查询参数
        userdata	apig自定义认证中设置的userdata

        表2 apigrequestcontext相关字段说明

        字段名	字段描述
        apiid	api的id
        requestid	此次api请求的requestid
        stage	发布环境名称

     2. apigtriggerresponse相关字段说明

        表3 apigtriggerresponse相关字段说明

        字段名	字段描述
        body	消息体
        headers	最终返回的http响应头
        statuscode	http状态码，int类型
        isbase64encoded	body是否经过base64编码，bool类型

        

        apigtriggerevent提供getrawbody()方法获取base64解码后的body体，相应的apigtriggerresponse提供setbase64encodedbody()方法来设置base64编码的body体。

  2. dis触发器相关字段说明

     表4 distriggerevent相关字段说明

     字段名	字段描述
     shardid	分区id
     message	dis消息体（dismessage结构）
     tag	函数版本
     streamname	通道名称

     表5 dismessage相关字段说明

     字段名	字段描述
     nextpartitioncursor	下一个游标
     records	消息记录（disrecord结构）
     millisbehindlatest	保留字段

     表6 disrecord相关字段说明

     字段名	字段描述
     partitionkey	数据分区
     data	数据
     sequencenumber	序列号（每个记录的唯一标识）

  3. kafka触发器相关字段说明

     表7 kafkatriggerevent相关字段说明

     字段名	字段描述
     instanceid	实例id
     records	消息记录（表8）
     triggertype	触发器类型，返回kafka
     region	region
     eventtime	事件发生时间，秒数
     eventversion	事件版本

     表8 kafkarecord相关字段说明

     字段名	字段描述
     messages	dms消息体
     topicid	dms的主题id

  4. smn触发器相关字段说明

     表9 smntriggerevent相关字段说明

     字段名	字段描述
     record	消息记录集合（smnrecord结构）

     表10 smnrecord相关字段说明

     字段名	字段描述
     eventversion	事件版本（当前为1.0）
     eventsubscriptionurn	订阅urn
     eventsource	事件源
     smn	smn事件消息体（smnbody结构）

     表11 smnbody相关字段说明

     字段名	字段描述
     topicurn	smn主题urn
     timestamp	消息时间戳
     messageatrributes	消息属性集合
     message	消息体
     type	消息类型
     messageid	消息id
     subject	消息主题

  5. 定时触发器相关字段说明

     表12 timertriggerevent相关字段说明

     字段名	字段描述
     version	版本名称（当前为“v1.0”）
     time	当前时间
     triggertype	触发器类型（“timer”）
     triggername	触发器名称
     userevent	触发器附加信息

  6. lts触发器相关字段说明

     表13 ltstriggerevent相关字段说明

     字段名	字段描述
     lts	lts消息（ltsbody结构）

     表14 ltsbody相关字段说明

     字段名	字段描述
     data	lts原始消息

     

     ltsbody提供getrawdata()函数返回base64解码后的消息。

  7. cts触发器相关字段说明

     表15 ctstriggerevent字段说明

     字段名	字段说明
     cts	cts消息体（表16）

     表16 cts结构相关字段说明

     字段名	字段描述
     time	事件产生时间
     user	触发该事件的用户信息（表17）
     request	事件请求内容
     response	事件响应内容
     code	响应码
     servicetype	事件触发的服务名称
     resourcetype	事件触发的资源类型
     resourcename	事件触发的资源名称
     resourceid	事件触发资源的唯一标识
     tracename	事件名称
     tracetype	事件触发的方式（如consoleaction：代表前台操作）
     recordtime	cts服务接收事件时间
     traceid	当前事件的唯一标识
     tracestatus	事件状态

     表17 user字段说明

     字段名	字段描述
     name	用户名（同一账号可以创建多个子用户）
     id	用户id
     domain	账号信息（表18）

     表18 domain字段说明

     字段名	字段描述
     name	账号名称
     id	账号id

  

  1. 例如使用apig触发器时，只需要把入口函数（假如函数名为handler）的第一个参数按照如下方式设置：handler(apigtriggerevent event, context context)。相关约束条件请参考base64解码和返回结构体的说明。
  2. 关于所有triggerevent，上面提到的triggerevent方法均有与之对应的set方法，建议在本地调试时使用；dis和lts均有对应的getrawdata()方法，但无与之相应的setrawdata()方法。
• context接口

  context接口提供函数获取函数执行上下文，例如，用户委托的accesskey/secretkey、当前请求id、函数执行分配的内存空间、cpu数等。

  context接口说明如表19所示。

  表19 context类上下文方法说明

  方法名	方法说明
  getrequestid( )	获取请求id。
  getremainingtimeinmilligetrunningtimeinsecondsseconds ( )	获取函数剩余运行时间。
  getaccesskey( )	获取用户委托的accesskey（有效期24小时），使用该方法需要为函数配置委托。 当前函数工作流已停止维护runtime sdk 中getaccesskey接口，您将无法使用getaccesskey获取临时ak。
  getsecretkey( )	获取用户委托的secretkey（有效期24小时），使用该方法需要为函数配置委托。 当前函数工作流已停止维护runtime sdk 中getsecretkey接口，您将无法使用getsecretkey获取临时sk。
  getsecurityaccesskey( )	获取用户委托的securityaccesskey（有效期24小时），缓存时间为10分钟，即10分钟内再次获取的返回内容相同，使用该方法需要为函数配置委托。
  getsecuritysecretkey( )	获取用户委托的securitysecretkey（有效期24小时），缓存时间为10分钟，即10分钟内再次获取的返回内容相同，使用该方法需要为函数配置委托。
  getsecuritytoken( )	获取用户委托的securitytoken（有效期24小时），缓存时间为10分钟，即10分钟内再次获取的返回内容相同，使用该方法需要为函数配置委托。
  getuserdata(string key)	通过key获取用户通过环境变量传入的值。
  getfunctionname( )	获取函数名称。
  getrunningtimeinseconds ( )	获取函数超时时间。
  getversion( )	获取函数的版本。
  getmemorysize( )	分配的内存。
  getcpunumber( )	获取函数占用的cpu资源。
  getpackage( )	获取函数组。
  gettoken( )	获取用户委托的token（有效期24小时），使用该方法需要为函数配置委托。
  getlogger( )	获取context提供的logger方法（默认会输出时间、请求id等信息）。
  getalias()	获取函数的别名

• 日志接口go sdk日志接口日志说明如表20所示。

  表20 日志接口说明表

  方法名	方法说明
  runtimelogger()	记录用户输入日志对象，包含方法如下：logf(format string, args ...interface{}) 该方法会将内容输出到标准输出，格式："时间-请求id-输出内容"，示例如下：2017-10-25t09:10:03.328z 473d369d-101a-445e-a7a8-315cca788f86 test log output。