SMN Event Source

Simple Message Notification (SMN) sends messages to email addresses, mobile phones, or HTTP/HTTPS URLs. If you create a function with an SMN trigger, messages published to a specified topic will be passed as a parameter to invoke the function. Then, the function processes the event, for example, publishing messages to other SMN topics or sending them to other cloud services. For details, see Using an SMN Trigger.

SMN example event

{
  "record": [
    {
      "event_version": "1.0",
      "smn": {
        "topic_urn": "urn:smn:{region}:0162c0f220284698b77a3d264376343a:{function_name}",
        "timestamp": "2018-01-09T07:11:40Z",
        "message_attributes": "None",
        "message": "this is smn message content",
        "type": "notification",
        "message_id": "a51671f77d4a479cacb09e2cd591a983",
        "subject": "this is smn message subject"
      },
      "event_subscription_urn": "urn:fss:{region}:0162c0f220284698b77a3d264376343a:function:default:read-smn-message:latest",
      "event_source": "smn"
    }
  ]
}

Parameter description

Parameter	Type	Example Value	Description
event_version	String	1.0	Event version
topic_urn	String	See the example.	ID of an SMN event
timestamp	String	2018-01-09T07:11:40Z	Time when an event occurs
message_attributes	Map	None	Message attributes
message	String	this is smn message content	Message content
type	String	notification	Event type
message_id	String	a51671f77d4a479cacb09e2cd591a983	Message ID. The ID of each message is unique.
subject	String	this is smn message subject	Subject of message
event_subscription_urn	String	See the example.	Subscription ID
event_source	String	smn	Event source

Example

handler.go

package main

import (
	"encoding/json"
	"fmt"

	"github.com/opentelekomcloud-community/otc-functiongraph-go-runtime/go-runtime/events/smn"
	"github.com/opentelekomcloud-community/otc-functiongraph-go-runtime/go-runtime/go-api/context"
	"github.com/opentelekomcloud-community/otc-functiongraph-go-runtime/go-runtime/pkg/runtime"
)

// Example for Simple Notification Service handler
func SmnTest(payload []byte, ctx context.RuntimeContext) (interface{}, error) {
	var smnEvent smn.SMNTriggerEvent
	err := json.Unmarshal(payload, &smnEvent)
	if err != nil {
		fmt.Println("Unmarshal failed")
		return "invalid data", err
	}
	ctx.GetLogger().Logf("payload:%s", smnEvent.String())
	return "ok", nil
}

func main() {
	runtime.Register(SmnTest)
}

last updated: 2025-10-24 14:39:45 UTC - commit: 373fe56a6b249d6515a713ff6d87064ece946718