Merge pull request #17 from penghuima/master

add events

Author: fanzhe328

events/README.md

@@ -8,3 +8,7 @@
 
 
 [SLS 事件格式](https://github.com/aliyun/fc-runtime-go-sdk/blob/master/events/README_SLS.md)
+
+[MNS Topic 事件格式](https://github.com/aliyun/fc-runtime-go-sdk/blob/master/events/README_MNS_Topic.md)
+
+[SLS Queue 事件格式](https://github.com/aliyun/fc-runtime-go-sdk/blob/master/events/README_MNS_Queue.md)

events/README_MNS_Queue.md

@@ -0,0 +1,58 @@
+## MNS Queue 触发器
+
+### Event 格式
+
+mns queue 触发器的 event 格式如下所示：
+
+```json
+{
+  "id":"c2g71017-6f65-fhcf-a814-a396fc8d****",
+  "source":"MNS-Function-mnstrigger",
+  "specversion":"1.0",
+  "type":"mns:Queue:SendMessage",
+  "datacontenttype":"application/json; charset=utf-8",
+  "subject":"acs:mns:cn-hangzhou:164901546557****:queues/zeus",
+  "time":"2021-04-08T06:28:17.093Z",
+  "aliyunaccountid":"1649015465574023",
+  "aliyunpublishtime":"2021-10-15T07:06:34.028Z",
+  "aliyunoriginalaccountid":"164901546557****",
+  "aliyuneventbusname":"MNS-Function-mnstrigger",
+  "aliyunregionid":"cn-chengdu",
+  "aliyunpublishaddr":"42.120.XX.XX",
+  "data":{
+    "requestId":"606EA3074344430D4C81****",
+    "messageId":"C6DB60D1574661357FA227277445****",
+    "messageBody":"TEST"
+  }
+}
+```
+
+### 使用示例
+
+下面展示了一个简单的 FC demo，当你为该函数配置 mns queue 触发器之后，每当你向 mns queue 发送任意消息之后，就会触发该函数，并返回消息内容。
+
+```go
+package main
+
+import (
+	"context"
+	"encoding/json"
+	"fmt"
+	"github.com/aliyun/fc-runtime-go-sdk/events"
+	"github.com/aliyun/fc-runtime-go-sdk/fc"
+	"github.com/aliyun/fc-runtime-go-sdk/fccontext"
+)
+
+func HandleRequest(ctx context.Context, event events.MnsQueueEvent) (string, error) {
+	fctx, _ := fccontext.FromContext(ctx)
+	flog := fctx.GetLogger()
+	mes, _ := json.Marshal(event)
+	flog.Info("event:", string(mes))
+	return fmt.Sprintf("MessageBody:%s", *event.Data.MessageBody), nil
+}
+
+func main() {
+	fc.Start(HandleRequest)
+}
+```
+

events/README_MNS_Topic.md

@@ -0,0 +1,67 @@
+## MNS Topic 触发器
+
+### Event 格式
+
+mns topic 触发器的 event 格式如下所示：
+
+- 若event格式设置为 JSON
+
+```json
+{
+  "TopicOwner":"topic account id",
+  "Message":"mock mns message",
+  "Subscriber":"subscriber account id",
+  "PublishTime":1658235558094,
+  "SubscriptionName":"test-5bf13c7e",
+  "MessageMD5":"652BF0E6297840015247C3xxxxxxx",
+  "TopicName":"fc-example",
+  "MessageId":"3405CA51807661353B3xxxxxxxx"
+}
+```
+- 若event格式设置为 STREAM
+
+```bash
+# 消息正文
+'hello topic'
+```
+### 使用示例
+
+下面展示了一个简单的 FC demo，当你为该函数配置 mns topic 触发器之后，每当你向 mns topic 发送任意消息之后，就会触发该函数，并返回消息内容。
+
+```go
+package main
+
+import (
+	"context"
+	"encoding/json"
+	"fmt"
+	"github.com/aliyun/fc-runtime-go-sdk/events"
+	"github.com/aliyun/fc-runtime-go-sdk/fc"
+	"github.com/aliyun/fc-runtime-go-sdk/fccontext"
+)
+
+func HandleRequest(ctx context.Context, event interface{}) (string, error) {
+	fctx, _ := fccontext.FromContext(ctx)
+	flog := fctx.GetLogger()
+	var topicEvent events.MnsTopicEvent
+	switch mess := event.(type) {
+	case string:
+		{
+			flog.Info("event:", event)
+			return fmt.Sprintf("MessageBody:%s", mess), nil
+		}
+	default:
+		result, _ := json.Marshal(mess)
+		_ = json.Unmarshal(result, &topicEvent)
+		flog.Info("event:", event)
+		return fmt.Sprintf("MessageBody:%s", *topicEvent.Message), nil
+	}
+
+}
+
+func main() {
+	fc.Start(HandleRequest)
+}
+
+```
+

events/README_OSS.md

@@ -60,7 +60,7 @@ import (
 	"github.com/aliyun/fc-runtime-go-sdk/events"
 )
 
-func HandleRequest(ctx context.Context, event OssEvent) (string, error) {
+func HandleRequest(ctx context.Context, event events.OssEvent) (string, error) {
 	fmt.Printf("hello,the name of your bucket is %s", *event.Events[0].Oss.Bucket.Name)
 	return fmt.Sprintf("hello,The size of the object you are manipulating is %dB",*event.Events[0].Oss.Object.Size), nil
 }

events/README_SLS.md

@@ -35,7 +35,7 @@ import (
 	"github.com/aliyun/fc-runtime-go-sdk/events"
 )
 
-func HandleRequest(ctx context.Context, event SlsEvent) (string, error) {
+func HandleRequest(ctx context.Context, event events.SlsEvent) (string, error) {
 	fmt.Printf("hello,the name of your logstoreName is %s", *event.Source.LogstoreName)
 	return fmt.Sprintf("hello,the name of your projectName is %s",*event.Source.ProjectName), nil
 }

events/mns-queue.go

@@ -0,0 +1,25 @@
+package events
+
+import "time"
+
+type MnsQueueEvent struct {
+	ID                      *string   `json:"id"`
+	Source                  *string   `json:"source"`
+	Specversion             *string   `json:"specversion"`
+	Type                    *string   `json:"type"`
+	Datacontenttype         *string   `json:"datacontenttype"`
+	Subject                 *string   `json:"subject"`
+	Time                    time.Time `json:"time"`
+	Aliyunaccountid         *string   `json:"aliyunaccountid"`
+	Aliyunpublishtime       time.Time `json:"aliyunpublishtime"`
+	Aliyunoriginalaccountid *string   `json:"aliyunoriginalaccountid"`
+	Aliyuneventbusname      *string   `json:"aliyuneventbusname"`
+	Aliyunregionid          *string   `json:"aliyunregionid"`
+	Aliyunpublishaddr       *string   `json:"aliyunpublishaddr"`
+	Data                    *Data     `json:"data"`
+}
+type Data struct {
+	RequestID   *string `json:"requestId"`
+	MessageID   *string `json:"messageId"`
+	MessageBody *string `json:"messageBody"`
+}

events/mns-topic.go

@@ -0,0 +1,14 @@
+package events
+
+import "time"
+
+type MnsTopicEvent struct {
+	TopicOwner       *string   `json:"TopicOwner"`
+	Message          *string   `json:"Message"`
+	Subscriber       *string   `json:"Subscriber"`
+	PublishTime      time.Time `json:"PublishTime"`
+	SubscriptionName *string   `json:"SubscriptionName"`
+	MessageMD5       *string   `json:"MessageMD5"`
+	TopicName        *string   `json:"TopicName"`
+	MessageID        *string   `json:"MessageId"`
+}