不走寻常路--MNS主题触发器的补充新玩法-阿里云开发者社区

开发者社区> 阿里云Serverless Compute> 正文

不走寻常路--MNS主题触发器的补充新玩法

简介: 目前还存在几个 region 的 MNS Topic 不能支持 MNS 主题触发器,本文提供一种workaround的方法

函数计算发布了新的触发器 MNS 主题触发器,这标志着函数计算的事件源新增加了一名成员 -- 消息服务(简称 MNS))主题, 但是根据官方文档MNS主题触发器描述,还存在以下几个 region 的 MNS Topic 不能支持 MNS 主题触发器:香港, 亚太东北 1(东京), 亚太东南 1(新加坡), 美国西部1(硅谷)。

问题

Q:这几个 region 的 Topic 就不能利用函数计算的 serverless 能力了吗?

A:老司机告诉你, 这个是可以的, 下面来看看怎么在秋名山上玩漂移。

image

解决方案

image

1. 创建函数,设置http trigger, 记得权限设置为匿名访问

2. 在 topic 上 订阅的推送类型为 http, 然后把函数设置http trigger 生成url 填入 接收端地址

注意:url 不要以 / 结尾,不然可能触发不了函数,后面记得填充一个任意的 path 值.

  • 函数设置 http trigger
    image
  • topic 增加 http 订阅
    image

发送消息到MNS主题实用代码片段

函数计算 python/nodejs/php 执行环境都已经内置有mns的相关sdk,直接编写相应的函数对MNS 进行操作即可,下面示例都是针对publish message 到 MNS 主题。

  • python

    # -*- coding: utf-8 -*-
    import logging
    from mns.account import Account
    from mns.topic import DirectMailInfo, DirectSMSInfo, TopicMessage
    
    access_key_id=<your ak id>
    access_key_secret=<your ak secret>
    endpoint = "http://<region>.mns.cn-qingdao.aliyuncs.com/"
    
    def handler(event, context):
      logger = logging.getLogger()
      logger.info(event)
      
      my_account = Account(endpoint, access_key_id, access_key_secret)
      topic_name = "test-topic"
      my_topic = my_account.get_topic(topic_name)
      #init TopicMessage
      msg_body = "I am test message."
      msg = TopicMessage(msg_body, "msg_tag")
      try:
          re_msg = my_topic.publish_message(msg)
          print "Publish Message Succeed. MessageBody:%s MessageID:%s" % (msg_body, re_msg.message_id)
      except MNSExceptionBase,e:
          if e.type == "TopicNotExist":
              print "Topic not exist, please create it."
              sys.exit(1)
          print "Publish Message Fail. Exception:%s" % e
      return 'hello world'
  • nodejs

    var AliMNS = require("ali-mns");
    var account = new AliMNS.Account("<your-account-id>", "<your-key-id>", "<your-key-secret>");
    var topic = new AliMNS.Topic(<topicName>, account, 'qingdao');
    
    module.exports.handler = function(event, context, callback) { 
      console.log('hello world');
      // send message
      topic.publishP("Hello MNS topic").done(function (data) { 
        callback(null, data);
        
      });
    };
    
  • php

    <?php
    use AliyunMNS\Client;
    use AliyunMNS\Requests\PublishMessageRequest;
    
    $accessId="<your-key-id>";
    $accessKey="<your-key-secret>";
    $endPoint = "http://<your-account-id>.mns.cn-qingdao.aliyuncs.com/";
    
    $client = new Client($endPoint, $accessId, $accessKey);
    
    function handler($event, $context) {
      $topicName = "test-topic";
      global $client;
      $topic = $client->getTopicRef($topicName);//获取Topic地址
      $messageBody = 'test message';  //消息内容
      $messageTag = 'pay_success';    //消息标签
      $request = new PublishMessageRequest($messageBody,$messageTag);
      $res = $topic->publishMessage($request);
      $res->isSucceed();
    
      return "OK";
    }

版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。

分享:
阿里云Serverless Compute
使用钉钉扫一扫加入圈子
+ 订阅

Serverless微服务应用实践分享

官方博客
函数计算官网