文档首页 > > 开发指南> 概述> 函数支持的事件源

函数支持的事件源

分享
更新时间: 2019/07/02 GMT+08:00

本节列出了FunctionGraph函数支持的华为云服务,可以将这些服务配置为FunctionGraph函数的事件源。在预配置事件源映射后,这些事件源检测事件时将自动调用FunctionGraph函数。

消息通知服务SMN

可以编写FunctionGraph函数来处理SMN的通知,在将消息发布到SMN主题时,服务可以通过将消息负载作为参数传递(SMN示例事件)来调用FunctionGraph函数,FunctionGraph函数代码可以处理事件,比如将消息发布到其他SMN主题或将消息发送到其他华为云服务。SMN消息触发的使用过程请参考使用SMN触发器

分布式消息服务DMS

可以将FunctionGraph函数配置为自动轮询DMS消息队列并处理任何新消息,FunctionGraph会定期轮询队列中的新消息,服务将轮询到的消息作为参数传递(DMS示例事件)来调用函数。DMS消息触发的使用过程请参考使用DMS触发器

API Gateway

可以通过HTTPS调用FunctionGraph函数,使用API Gateway自定义REST API和终端节点来实现。可以将各个API操作(如GET和PUT)映射到特定的FunctionGraph函数,当向该API终端节点发送HTTPS请求时(APIG示例事件),API Gateway会调用相应的FunctionGraph函数。HTTPS调用触发函数的使用过程请参考使用APIG触发器

对象存储服务OBS

可以编写FunctionGraph函数来处理OBS存储桶事件,例如对象创建事件或对象删除事件。当用户将一张照片上传到存储桶时,OBS存储桶调用FunctionGraph函数,实现读取图像和创建照片缩略图。OBS对象操作触发函数的过程请参考使用OBS触发器

数据接入服务DIS

可以将FunctionGraph函数配置为自动轮询流并处理任何新记录,例如网站点击流、财务交易记录、社交媒体源、IT日志和位置跟踪事件等(DIS示例事件)。FunctionGraph会定期轮询DIS数据流中的新记录。DIS数据流触发函数的过程请参考使用DIS触发器

定时触发器TIMER

可以使用TIMER的计划事件功能定期调用您的代码,可以指定固定频率(分钟、小时、天数)或指定 cron 表达式定期调用函数(TIMER示例事件)。定时触发器的使用请参考使用定时触发器

日志触发器LTS

可以编写FunctionGraph函数来处理云日志服务订阅的日志,当云日志服务采集到订阅的日志后,可以通过将采集到的日志作为参数传递(LTS示例事件)来调用FunctionGraph函数,FunctionGraph函数代码可以对其进行自定义处理、分析或将其加载到其他系统。LTS日志触发的使用过程请参考使用LTS触发器

云审计服务触发器CTS

可以编写FunctionGraph函数,根据CTS云审计服务类型和操作订阅所需要的事件通知,当CTS云审计服务获取已订阅的操作记录后,通过CTS触发器将采集到的操作记录作为参数传递(CTS示例事件)来调用FunctionGraph函数。经由函数对日志中的关键信息进行分析和处理,对系统、网络等业务模块进行自动修复,或通过短信、邮件等形式产生告警,通知业务人员进行处理。CTS触发器的使用请参考使用CTS触发器

云监控服务

FunctionGraph函数实现了与云监控服务对接,函数上报云监控服务的监控指标,用户可以通过云监控服务来查看函数产生的监控指标和告警信息。查看监控指标请参考查看监控图标

示例事件

  • SMN示例事件

    示例函数名为test,smn主题为serverless_Test,对应的SMN事件内容如下(消息头为"subject"字段,消息体为"message"字段):

    {
        "record": [{
            "event_version": "1.0",
            "smn": {
                "message_attributes": null,
                "subject": "This is the message title of smn trigger",
                "message_id": "a5dbd701d70d4ac2a153e7dd6dd9b601",
                "topic_urn": "urn:smn:cn-north-1:bb8695913bb74682b9ca82a8803b60d8:serverless_Test",
                "type": "notification",
                "message": "This is the message body of smn trigger",
                "timestamp": "2017-11-15T04:02:24Z"
                },
            "event_source": "smn",
            "event_subscription_urn": "urn:fss:cn-north-1:bb8695913bb74682b9ca82a8803b60d8:function:default:obsTrigger-Test1:latest"
        }],
        "functionname": "test",
        "requestId": "7c307f6a-cf68-4e65-8be0-4c77405a1b2c",
        "timestamp": "Wed Nov 15 2017 12:00:00 GMT+0800 (CST)"
    }

  • DMS示例事件

    示例函数名为test,那么对应内容如下(消息体在Messages中,Body为消息内容,Attributes为在DMS生成消息页面添加的属性,QueueID为队列ID,ConsumerGroupId是消费组ID。)

    {
        "Tag": "latest",
        "QueueID": "48d11a53-e498-4964-84a2-aaa56442d5ca",
        "ConsumerGroupID": "g-61d9d290-7dae-4144-9ce7-00b9f159cdbe",
        "Messages": [{
            "Body": "This is dms trigger body",
            "Attributes": {
                "dmstrigger": "dmstrigger",
                "dmstrigger2": "dmstrigger"
            }
        }],
        "functionname": "test",
        "requestId": "57453335-ccf7-4d43-8639-79d108158749",
        "timestamp": "Wed Nov 15 2017 14:26:10 GMT+0800 (CST)"
    }
  • APIG示例事件

    APIG事件说明如下。

    {
        "httpMethod": "GET",     //请求方法
        "path": "/test/hello",   //请求路径
        "pathParameters": {      //路径参数
            "proxy": "hello"
        },
        "queryStringParameters": { //查询参数
            "name": "me"
        },
        "headers": {               //请求头
            "x-stage": "RELEASE",
            "Host": "3f96e175-d5e4-4d4b-ae7e-f6d264e63b23-apigw.cn-north-1.huaweicloud.com",
            "User-Agent": "lua-resty-http/0.10 (Lua) ngx_lua/10008",
            ……
        },
        "body": "……",              //请求体
        "isBase64Encoded":false/true,  //body是否base64
        "requestContext": {
            "stage": "test",          //环境别名
            "requestId": "dd4337362c02c7d77299e78781beb4b1",
            "apiId": "41b45ea3-70b5-11e6-b7bd-69b5aaebc7d9"
        },

    }

    函数应按以下结构返回字符串。

    {
        "isBase64Encoded": true|false,
        "statusCode": httpStatusCode,
        "headers": {"headerName":"headerValue",...},
        "body": "..."
    }
  • DIS示例事件

    示例数据流名称为dis-swtest,那么利用该数据流创建触发器的函数收到的请求格式为(消息在Message中)。

    {
        "ShardID": "shardId-0000000000",
        "Message": {
            "next_partition_cursor": "eyJnZXRJdGVyYXRvclBhcmFtIjp7InN0cmVhbS1uYW1lIjoiZGlzLXN3dGVzdCIsInBhcnRpdGlvbi1pZCI6InNoYXJkSWQtMDAwMDAwMDAwMCIsImN1cnNvci10eXBlIjoiVFJJTV9IT1JJWk9OIiwic3RhcnRpbmctc2VxdWVuY2UtbnVtYmVyIjoiNCJ9LCJnZW5lcmF0ZVRpbWVzdGFtcCI6MTUwOTYwNjM5MjE5MX0",
            "records": [{
                "partition_key": "shardId_0000000000",
                "data": "PEJ1ZmZlcj48L0J1ZmZlcj4=",
                "sequence_number": "0"
            },
            {
                "partition_key": "shardId_0000000000",
                "data": "PEJ1ZmZlcj48L0J1ZmZlcj4=",
                "sequence_number": "1"
            },
            {
                "partition_key": "shardId_0000000000",
                "data": "PEJ1ZmZlcj48L0J1ZmZlcj4=",
                "sequence_number": "2"
            },
            {
                "partition_key": "shardId_0000000000",
                "data": "PEJ1ZmZlcj48L0J1ZmZlcj4=",
                "sequence_number": "3"
            }],
            "millis_behind_latest": ""
        },
        "Tag": "latest",
        "StreamName": "dis-swtest"
    }
  • TIMER示例事件
    {
      "version": "v1.0",
      "time": "2006-01-02T15:04:05-07:00",  // 本地时间
      "trigger_type": "TIMER",   // 触发器类型
      "trigger_name": "触发器名称",
      "user_event": "用户配置事件"   //该字段内容为用户在创建定时触发器时配置的用户事件
    }
  • LTS示例事件
    {
        "lts": {
        "data": "eyJsb2dzIjpbIntcIm1lc3NhZ2VcIjpcIjIwMTgtMDYtMjYvMTg6NDA6NTMgW0lORl0gW2NvbmZpZy5nbzo3Ml0gU3VjY2Vzc2Z1bGx5IGxvYWRlZCBnZW5lcmFsIGNvbmZpZ3VyYXRpb24gZmlsZVxcclxcblwiLFwidGltZVwiOjE1MzAwMDk2NTMwNTksXCJob3N0X25hbWVcIjpcImVjcy10ZXN0YWdlbnQubm92YWxvY2FsXCIsXCJpcFwiOlwiMTkyLjE2OC4xLjk4XCIsXCJwYXRoXCI6XCIvdXNyL2xvY2FsL3RlbGVzY29wZS9sb2cvY29tbW9uLmxvZ1wiLFwibG9nX3VpZFwiOlwiNjYzZDY5MzAtNzkyZC0xMWU4LThiMDgtMjg2ZWQ0ODhjZTcwXCIsXCJsaW5lX25vXCI6NjE1fSIsIntcIm1lc3NhZ2VcIjpcIjIwMTgtMDYtMjYvMTg6NDA6NTMgW1dSTl0gW2NvbmZpZy5nbzo4Ml0gVGhlIHByb2plY3RJZCBvciBpbnN0YW5jZUlkIG9mIGNvbmZpZy5qc29uIGlzIG5vdCBjb25zaXN0ZW50IHdpdGggbWV0YWRhdGEsIHVzZSBtZXRhZGF0YS5cXG5cIixcInRpbWVcIjoxNTMwMDA5NjUzMDU5LFwiaG9zdF9uYW1lXCI6XCJlY3MtdGVzdGFnZW50Lm5vdmFsb2NhbFwiLFwiaXBcIjpcIjE5Mi4xNjguMS45OFwiLFwicGF0aFwiOlwiL3Vzci9sb2NhbC90ZWxlc2NvcGUvbG9nL2NvbW1vbi5sb2dcIixcImxvZ191aWRcIjpcIjY2M2Q2OTMwLTc5MmQtMTFlOC04YjA5LTI4NmVkNDg4Y2U3MFwiLFwibGluZV9ub1wiOjYxNn0iLCJ7XCJtZXNzYWdlXCI6XCIgSW4gY29uZi5qc29uLCBwcm9qZWN0SWQgaXMgW10sIGluc3RhbmNlSWQgaXMgW10uIE1ldGFEYXRhIGlzIHs0NTQzMjkzYS01YjJjLTQ0YzQtYjdhMC1kZTIxOGY3ZjJmYTYgNjI4MGUxNzBiZDkzNGY2MGE0ZDg1MWNmNWNhMDUxMjkgIH1cXHJcXG5cIixcInRpbWVcIjoxNTMwMDA5NjUzMDU5LFwiaG9zdF9uYW1lXCI6XCJlY3MtdGVzdGFnZW50Lm5vdmFsb2NhbFwiLFwiaXBcIjpcIjE5Mi4xNjguMS45OFwiLFwicGF0aFwiOlwiL3Vzci9sb2NhbC90ZWxlc2NvcGUvbG9nL2NvbW1vbi5sb2dcIixcImxvZ191aWRcIjpcIjY2M2Q2OTMwLTc5MmQtMTFlOC04YjBhLTI4NmVkNDg4Y2U3MFwiLFwibGluZV9ub1wiOjYxN30iXSwib3duZXIiOiI2MjgwZTE3MGJkOTM0ZjYwYTRkODUxY2Y1Y2EwNTEyOSIsImxvZ19ncm91cF9pZCI6Ijk3YTlkMjg0LTQ0NDgtMTFlOC04ZmE0LTI4NmVkNDg4Y2U3MCIsImxvZ190b3BpY19pZCI6IjFhOTY3NWE3LTc4NGQtMTFlOC05ZjcwLTI4NmVkNDg4Y2U3MCJ9"
        }
    }
  • CTS示例事件
    {
    	"cts": {
    		"time": "2018/06/26 08:54:07 GMT+08:00", //timestamp, 发送方产生
    		"user": { // 本次请求发起用户信息
    			"name": "userName",
    			"id": "5b726c4fbfd84821ba866bafaaf56aax",
    			"domain": {
    				"name": "domainName",
    				"id": "b2b3853af40448fcb9e40dxj89505ba"
    			}
    		},
    		"request": {}, //事件请求内容
    		"response": {}, //事件响应内容
    		"code": 204, //事件响应码 例如200,400
    		"service_type": "FunctionGraph", //发送方的简写,比如VPC,ECS等等
    		"resource_type": "graph", //发送方资源类型,比如vm,vpn等等
    		"resource_name": "workflow-2be1", //资源名称,例如ecs服务中某个虚拟机的名称
    		"resource_id": "urn:fgs:cn-north-1:2d1d891d93054bbaa69b9e866c0971ac:graph:workflow-2be1", //源id,例如ecs服务中某个虚拟机的id
    		"trace_name": "deleteGraph", //事件名称比如:startServer, shutDown等
    		"trace_type": "ConsoleAction", //事件发生源头类型例如ApiCall
    		"record_time": "2018/06/26 08:54:07 GMT+08:00", //cts服务接受到这条trace的时间
    		"trace_id": "69be64a7-0233-11e8-82e4-e5d37911193e", //当前trace唯一标示
    		"trace_status": "normal"
    	}
    }
分享:

    相关文档

    相关产品

文档是否有解决您的问题?

提交成功!

非常感谢您的反馈,我们会继续努力做到更好!

反馈提交失败,请稍后再试!

*必选

请至少选择或填写一项反馈信息

字符长度不能超过200

提交反馈 取消

如您有其它疑问,您也可以通过华为云社区问答频道来与我们联系探讨

跳转到云社区