调用HTTP协议的SDK收发普通消息
usr/bin/env python#coding=utf8 import sys from mq_http_sdk.mq_exception import MQExceptionBase frommq_http_sdk.mq_producer import*from mq_http_sdk.mq_client import*import time#初始化Client。mq_client=MQClient(#设置HTTP接入域名...
背景信息
OLAP场景中，为避免复杂SQL运行时间过长，程序一直阻塞等待而影响业务运行，DLA推出异步执行SQL功能，即在SQL中加入Hint/*+run-async=true*/。异步执行SQL时，查询结果将默认写入您的OSS目录中，同时系统...oa-query-results-${您的uid}-oss-...
GetMqSofamqMessageById
根据指定的 Message ID，查询消息。...Action=GetMqSofamqMessageById&Cell=RZ01A&InstanceId=MQ_INST_111111111111_DOxxxxxx&MsgId=1E0578FE110F18B4AAC235C05F2*&Topic=test-mq_topic&<公共请求参数>正常返回示例 XML 格式 ...
收发顺序消息
instance_id="${INSTANCE_ID}"consumer=mq_client.get_consumer(instance_id,topic_name,group_id)#长轮询顺序消费消息,拉取到的消息可能是多个分区的（对于分区顺序消息），一个分区内的消息一定是顺序的。对于分区顺序消息，只要一个分区...
快速入门
Resource":"acs:oss:*:*:*"},{"Effect":"Allow","Action":"mq:QueryInstanceBaseInfo","Resource":"acs:mq:*:*:*"}]} 在 RAM控制台 的 身份管理>用户 中，找到RAM子账户，单击操作列的 添加权限，选择上一步创建的自定义策略，和 系统策略...
收发定时消息和延时消息
import sys from mq_http_sdk.mq_exception import MQExceptionBase frommq_http_sdk.mq_producer import*from mq_http_sdk.mq_client import*import time#初始化client。mq_client=MQClient(#设置HTTP协议客户端接入点，进入消息队列RocketMQ版...
版本说明
mq-http-java-sdk-1.0.3.2.zip 1.0.3.1 发布时间 发布内容 下载 2021-12-13 功能优化 Log4j版本升级至2.15.0。mq-http-java-sdk-1.0.3.1.zip 1.0.3 发布时间 发布内容 下载 2021-01-05 新特性 支持顺序消息。mq-...
MQ订阅消息
通过MQ订阅系统消息格式说明。消息定义 消息体 字段 类型 说明 EventCatgory String 事件分类，取值范围："DEVICE"：设备事件"BIZ":业务事件 Event String 事件说明："DEVICE_OFFLINE":设备下线"DEVICE_PROPERTY"：设备属性变更"BIZ_...
业务流量隔离功能实践
统一管控难 要实现HTTP、RPC、MQ、任务调度等流量的隔离，需对接支持众多云产品和开源框架。无业务代码侵入难 要实现HTTP、RPC、MQ、任务调度等流量管控能力，通常需要业务应用配合改造，对业务代码侵入大。和容灾流量规则共存时，兼容不...
QueryMqSofamqMessageByTopic
Action=QueryMqSofamqMessageByTopic&BeginTime=1570723200000&Cell=RZ01A&EndTime=1570809600000&InstanceId=MQ_INST_111111111111_DOxxxxxx&PageNum=1&PageSize=20&TaskId=0BC1310300002A9F000021E4D7A48346&Topic=test-mq_topic&<公共...
服务关联角色
关联角色介绍 角色名称：AliyunServiceRoleForLinkcard 权限说明：{"Version":"1","Statement":[{"Effect":"Allow","Action":["mq:QueryInstanceBaseInfo","mq:QueryTopicStatus","mq:PUB"],"Resource":"*"},{"Action":"ram:...
收发事务消息
usr/bin/env python#coding=utf8 import sys from mq_http_sdk.mq_exception import MQExceptionBase frommq_http_sdk.mq_producer import*from mq_http_sdk.mq_client import*import time import threading#初始化client。mq_client=MQClient(#...
GetMqSofamqDLQMessageById
Action=GetMqSofamqDLQMessageById&Cell=RZ01A&GroupId=GID_test_group_id&InstanceId=MQ_INST_111111111111_DOxxxxxx&MsgId=0BC16699165C03B925DB8A404E2D*&<公共请求参数>正常返回示例 XML 格式<RequestId>861E6630-AEC0-4B2D-B214-6CB5E...
版本说明
mq-http-php-sdk-1.0.4.zip 1.0.3.1 发布时间 发布内容 下载 2021-12-13 问题修复 修复了PHP 5.5的兼容性问题。mq-http-php-sdk-1.0.3.1.zip 1.0.3 发布时间 发布内容 下载 2021-01-05 新特性 支持顺序消息。问题修复 修复了GuzzleHttp 7的...
Hints
对应的hint组合如下：ONS /*+run-async=true,mq-notify-by=ons,mq-topic=${您的ons的topic},mq-producer-id=${您的group Id},mq-endpoint=${您的某个endpoint，与DLA所在region相同}*/ mq-notify-by：消息渠道的名称 mq-topic：ons的...
收发普通消息
private static MQClient_client=new Aliyun.MQ.MQClient(_accessKeyId,_secretAccessKey,_endpoint);static MQProducer producer=_client.GetProducer(_instanceId,_topicName);static void Main(string[]args){ try {/循环发送4条消息。...
数据出口
Link WAN支持通过阿里云物联网平台流转数据，也支持用户自建云服务流转数据。数据出口至 物联网平台控制台，...节点分组N:1映射到产品设备列表 节点分组N:1映射到MQ消息队列的Topic 说明 N:1汇聚到消息队列MQ的Topic，数据流转至自建云服务
准备环境
其中 Aliyun_MQ_SDK 为SDK所在目录，Aliyun_MQ_SDK.sln 为工程文件。使用Visual Studio打开 Aliyun_MQ_SDK.sln 文件导入工程。执行 Samples.cs 文件。在Aliyun_MQ_SDK工程中可以看到 Samples.cs 文件，该文件中提供了C#SDK消息收发的示例...
RocketMQ触发器
{"id":"94ebc15f-f0db-4bbe-acce-56fb72fb*","source":"RocketMQ-Function-rocketmq-trigger","specversion":"1.0","type":"mq:Topic:SendMessage","datacontenttype":"application/json;charset=utf-8","subject":"acs:mq:...
QueryMqSofamqDLQMessageByGroupId
Action=QueryMqSofamqDLQMessageByGroupId&BeginTime=1570723200000&Cell=RZ01A&EndTime=1570809600000&GroupId=GID_test_group_id&InstanceId=MQ_INST_111111111111_DOxxxxxx&PageNum=1&PageSize=10&TaskId=0BC1310300002A9F000021E4D7A...
ListTagResources-查询资源绑定的标签列表
CartService 示例 正常返回示例 JSON 格式 {"NextToken":"caeba0*be03f84eb48b699f0a4883","RequestId":"301D2CBE-66F8-403D-AEC0-82582478*","TagResources":[{"ResourceType":"ALIYUN:MQ:TOPIC","InstanceId":"MQ_INST_188077086902*_...
收发顺序消息
private static MQClient_client=new Aliyun.MQ.MQClient(_accessKeyId,_secretAccessKey,_endpoint);static MQProducer producer=_client.GetProducer(_instanceId,_topicName);static void Main(string[]args){ try {/循环发送8条消息。...
mPaaS 框架介绍
mPaaS iOS 框架源自支付宝客户端的开发框架，基于 Framework 的设计思想，将业务隔离成相对独立的模块，并着力追求模块与模块之间高內聚、低耦合。mPaaS iOS 框架直接接管应用的生命周期，负责整个应用启动托管、应用生命周期管理、处理与...
RocketMQ触发器
[{"id":"94ebc15f-f0db-4bbe-acce-56fb72fb*","source":"RocketMQ-Function-rocketmq-trigger","specversion":"1.0","type":"mq:Topic:SendMessage","datacontenttype":"application/json;charset=utf-8","subject":"acs:mq:...
版本说明
mq-http-csharp-sdk-1.0.5.zip 1.0.3 发布时间 发布内容 下载 2021-01-05 新特性 支持顺序消息。mq-http-csharp-sdk-1.0.3.zip 1.0.1 发布时间 发布内容 下载 2019-06-10 新特性 支持高级特性消息，包括定时和延时消息、事务消息，暂不支持...
公共参数
公共请求头 参数 是否必选 说明 Authorization 是 验证字符串，由 MQ+空格+<AccessKeyId>+:+构成，更多信息，请参见 签名机制。Content-Length 是 HTTP请求Body的长度。Content-Type 是 请求内容的MIME类型，目前请求仅支持text/xml;...
OnsInstanceBaseInfo-查询实例基本信息和收发消息的接...
操作 访问级别 资源类型 条件关键字 关联操作 mq:OnsInstanceBaseInfo Read 全部资源*无 无 请求参数 名称 类型 必填 描述 示例值 InstanceId string 是 需查询实例的 ID。MQ_INST_138015630679*_BAAy1Hac 返回参数 名称 类型 描述 示例值 ...
自定义事件源消息队列RocketMQ版
事件示例 {"id":"94ebc15f-f0db-4bbe-acce-56fb72fb*","source":"acs:mq","specversion":"1.0","type":"mq:Topic:SendMessage","datacontenttype":"application/json;charset=utf-8","subject":"acs:mq:cn-hangzhou:123456789098*:MQ_INST_...
收发定时消息和延时消息
private static MQClient_client=new Aliyun.MQ.MQClient(_accessKeyId,_secretAccessKey,_endpoint);static MQProducer producer=_client.GetProducer(_instanceId,_topicName);static void Main(string[]args){ try {/循环发送4条消息。...
微消息队列MQTT版推送事件到函数计算
public class MQ4IoTProducerDemo { public static void main(String[]args)throws Exception {/*MQ4IOT实例ID，购买后控制台获取。String instanceId="XXXXX;接入点地址，购买MQ4IOT实例，且配置完成后即可获取，接入点地址必须填写分配的...
OnsConsumerTimeSpan-查询Topic可重置时间范围
MQ_INST_111111111111_DOxxxxxx 示例 正常返回示例 JSON 格式 {"RequestId":"A07E3902-B92E-44A6-B6C5-6AA111111*","Data":{"MaxTimeStamp":1570761026804,"ConsumeTimeStamp":1570761026400,"Topic":"test-mq_topic","MinTimeStamp":...
云消息队列 RocketMQ 版
MQ_INST_115964845466*_ByBeUp3p Topic 选择生产 消息队列RocketMQ版 消息的Topic。topic Tag 配置源实例中用于过滤消息的Tag。test Group ID 选择源实例中的消费组名称。请使用独立的消费组来创建事件源，不要和已有的业务混用消费组，...
使用Canal和RocketMQ实现数据库变更订阅处理
8 \-e canal.instance.tsdb.enable=true \-e canal.instance.gtidon=false \-e canal.serverMode=rocketMQ \-e canal.aliyun.accessKey=xxx \-e canal.aliyun.secretKey=xxx \-e canal.mq.accessChannel=cloud \-e rocketmq.namesrv.addr='...
收发普通消息
System.out.println(new Date()+"Send mq message success.Topic is:"+topic+",msgId is:"+pubResultMsg.getMessageId()+",bodyMD5 is:"+pubResultMsg.getMessageBodyMD5());} } catch(Throwable e){/消息发送失败，需要进行重试处理，可...
节点分组
消息队列（MQ）：数据流转到MQ的Topic。调试转发 当 数据出口 为 阿里云物联网平台 时，出现此参数。用于控制调试开关。开：数据流转至基础Topic和物模型Topic。关：数据仅流转至物模型Topic。数据目的地 当 数据出口 为 阿里云物联网平台 ...
订阅数据示例
MQ4IOT clientId，由业务系统分配，需要保证每个 tcp 连接都不一样，保证全局唯一，如果不同的客户端对象（tcp 连接）使用了相同的 clientId 会导致连接异常断开。clientId 由两部分组成，格式为 GroupID@DeviceId，其中 groupId 在 MQ4IOT...
收发普通消息
i+{ var msg mq_http_sdk.PublishMessageRequest msg = mq_http_sdk.PublishMessageRequest{ MessageBody: "hellomq!消息内容。MessageTag:"",/消息标签。Properties:map[string]string{},/消息属性。}/设置消息的Key。msg.MessageKey=...
加载框架与定制
mPaaS Android 框架提供了一整套的加载逻辑。基于此框架，研发团队可以进行多业务线开发。本文描述框架的启动流程以及如何在框架下添加自己的代码以对接启动。启动流程 Application 传统 Android apk 运行时首先加载 AndroidManifest 文件 ...
OnsMessageGetByMsgId-通过MsgId查询消息
操作 访问级别 资源类型 条件关键字 关联操作 mq:QueryMessage Read 全部资源*无 无 请求参数 名称 类型 必填 描述 示例值 MsgId string 是 需查询的消息的 ID，即 Message ID。1E0578FE110F18B4AAC235C05F2*Topic string 是 需查询的消息...
ResetMqSofamqConsumerOffset
重置指定的 Group ID 的消费位点到指定时间戳。...Action=ResetMqSofamqConsumerOffset&GroupId=GID_test_consumer_id&InstanceId=MQ_INST_111111111111_DOxxxxxx&Topic=test-mq-topic&Type=1&<公共请求参数>正常返回示例 XML 格式 ...
- 产品推荐
- 这些文档可能帮助您