Use Knative to manage MnsOss event sources

Step 1: Deploy MnsOss

1. On the details page of the cluster, choose Applications > Knative.
2. On the Components tab, find MnsOss and click Deploy in the Actions column.
3. In the Deploy MnsOss message, click Confirm.

Step 2: Configure OSS event notification settings

Step 3: Create an MNS token

1. In the left-side navigation pane, click Topics.
2. In the top navigation bar of the MNS console, select the region where your cluster is deployed.
3. On the Topics page, click the topic that you want to manage.
4. On the Topics page, click Get Endpoint in the upper-right corner of the page.
5. In the Endpoint section of the Topic Details page, copy the public endpoint.
6. Obtain an AccessKey ID and AccessKey secret of the current account. For more information, see How can I obtain an AccessKey ID and AccessKey secret?.
7. Run the following command to encode the public endpoint, AccessKey ID, and AccessKey secret by using Base64. Then, a token is generated.

   echo '{ "url":"https://xxxx.mns.cn-shanghai.aliyuncs.com/", "accessKeyId":"xxx","accessKeySecret":"xx" }' | base64

8. Create a Secret to store and manage the token.
   1. Create a file named mnsoss-secret.yaml.

      apiVersion: v1
      kind: Secret
      metadata:
        name: mnsoss-secret
      type: Opaque
      data:
        mns: eyAidXJsIjoiaHR0cHM6Ly94eHh4Lm1ucy5jbi1zaGFuZ2hhaS5hbGl5dW5jcy5jb20vIiwgImFjY2Vzc0tleUlkIjoieHh4IiwiYWNjZXNzS2V5U2VjcmV0IjoieHgiIH0K

      Replace the value of mns with the token that is generated in Step 7.

   2. Run the following command to create a Secret:

      kubectl apply -f mnsoss-secret.yaml

Step 4: Create a service account and a service broker

1. Create a service account.
   1. Create a file named mnsoss-sa.yaml.

      apiVersion: rbac.authorization.k8s.io/v1
      kind: ClusterRoleBinding
      metadata:
        name: eventing-sources-mnsoss
      subjects:
      - kind: ServiceAccount
        name: mnsoss-sa
        namespace: default
      roleRef:
        apiGroup: rbac.authorization.k8s.io
        kind: ClusterRole
        name: eventing-sources-mnsoss-controller
      ---
      apiVersion: v1
      kind: ServiceAccount
      metadata:
        name: mnsoss-sa

   2. Run the following command to create a service account:

      kubectl apply -f mnsoss-sa.yaml

2. Run the following command to create a service broker:

   kubectl label namespace default knative-eventing-injection=enabled

Step 5: Create an MnsOss event source

To receive MnsOss events, you must create an MnsOss event source.

1. Create a file named mnsoss-source.yaml.

   apiVersion: sources.eventing.knative.dev/v1alpha1
   kind: MnsOssSource
   metadata:
     labels:
       controller-tools.k8s.io: "1.0"
     name: mnsoss-face
   spec:
     # Add fields here
     serviceAccountName: mnsoss-sa
     accessToken:
       secretKeyRef:
         name: mnsoss-secret
         key: mns
     sink:
       apiVersion: eventing.knative.dev/v1alpha1
       kind: Broker
       name: default
     topic: mns-en-topics-oss-face-image-2381221888dds9129

   Set topic to the name of the topic that is generated in the MNS console.

2. Run the following command to create an MnsOss event source:

   kubectl  apply -f mnsoss-source.yaml

Step 6: Create a Knative Service

Create a Knative Service to verify whether the created MnsOss event source works as normal. A Knative Service named event-display is created in this example.

1. Create a file named service.yaml.

   apiVersion: serving.knative.dev/v1alpha1
   kind: Service
   metadata:
     name: event-dispaly
     namespace: default
   spec:
     template:
       spec:
         containers:
         - image: registry.cn-hangzhou.aliyuncs.com/knative-sample/event-display:1215

2. Run the following command to create a Knative Service:

   kubectl apply -f service.yaml

Step 7: Create a trigger

Create a trigger to subscribe to OSS events.

1. Create a file named trigger.yaml.

   apiVersion: eventing.knative.dev/v1alpha1
   kind: Trigger
   metadata:
     name: oss-trigger
     namespace: default
   spec:
     subscriber:
       ref:
         apiVersion: serving.knative.dev/v1alpha1
         kind: Service
         name: event-dispaly

2. Run the following command to create a trigger:

   kubectl apply -f trigger.yaml

Check results

2020/12/16 13:04:19 receive cloudevents.Event:
{"events": [{
            "eventName": "ObjectCreated:PostObject",
            "eventSource": "acs:oss",
            "eventTime": "2019-06-18T06:44:16.000Z",
            "eventVersion": "1.0",
            "oss": {
                "bucket": {
                    "arn": "acs:oss:cn-beijing:1041208914252405:testjian",
                    "name": "testjian",
                    "ownerIdentity": "1041208914252405",
                    "virtualBucket": ""},
                "object": {
                    "deltaSize": 0,
                    "eTag": "137138904F2E18D307D04EB38EA44CDA",
                    "key": "timg.jpg",
                    "size": 12990},
                "ossSchemaVersion": "1.0",
                "ruleId": "demo-i****"},
            "region": "cn-beijing",
            "requestParameters": {"sourceIPAddress": "42.120.7*.***"},
            "responseElements": {"requestId": "5D08884070BC12B192C6****"},
            "userIdentity": {"principalId": "104120891425****"}}]} "137138904F2E18D307D04EB38EA44CDA",
                    "key": "timg.jpg",
                    "size": 12990},
                "ossSchemaVersion": "1.0",
                "ruleId": "demo-i****"},
            "region": "cn-beijing",
            "requestParameters": {"sourceIPAddress": "42.120.7*.***"},
            "responseElements": {"requestId": "5D08884070BC12B192C6****"},
            "userIdentity": {"principalId": "104120891425****"}}]}