AliyunMQReadOnlyAccess
策略详情 类型：系统策略 创建时间：2019-10-23 12:17:19 更新时间：2022-08-04 03:46:37 当前版本：v4 策略内容 {"Version":"1","Statement":[{"Action":["mq:OnsInstanceBaseInfo","mq:List*","mq:Query*","mq:Get*","mq:Download*",...
调用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)#长轮询顺序消费消息,拉取到的消息可能是多个分区的（对于分区顺序消息），一个分区内的消息一定是顺序的。对于分区顺序消息，只要一个分区...
旧版样例简介
sample-mq-consumer：该工程主要为上述案例中的 MQ 消息提供者（provider）提供一个消费者（consumer）案例，该工程不依赖 GTS，仅为方便用户理解 MQ 案例。sample-txc-edas：在 EDAS 上使用 GTS 的案例，该案例综合了 GTS、EDAS 及 MQ 的...
应用场景
通用分布式事务管理 提供通用的分布式事务管理能力，支持微服务框架（Spring Cloud、Dubbo 和 HSF）、数据库（DRDS、RDS、MySQL、Oracle等）、消息中间件（MQ）的组合使用，灵活方便。多业务场景：通过混合事务，GTS可以应用到金融、电信、...
收发定时消息和延时消息
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_...
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的...
收发普通消息
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消息收发的示例...
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条消息。...
版本说明
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;...
自定义事件源消息队列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条消息。...
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){/消息发送失败，需要进行重试处理，可...
收发普通消息
i+{ var msg mq_http_sdk.PublishMessageRequest msg = mq_http_sdk.PublishMessageRequest{ MessageBody: "hellomq!消息内容。MessageTag:"",/消息标签。Properties:map[string]string{},/消息属性。}/设置消息的Key。msg.MessageKey=...
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 格式 ...
发送消息（多线程）
} } catch(Exception e){/消息发送失败，需要进行重试处理，可重新发送这条消息或持久化这条数据进行补偿处理 System.out.println(new Date()+"Send mq message failed.Topic is:"+MqConfig.TOPIC);e.printStackTrace();} } });thread....
OnsMessageGetByKey-根据Message Key查询消息
操作 访问级别 资源类型 条件关键字 关联操作 mq:QueryMessage Read 全部资源*无 无 请求参数 名称 类型 必填 描述 示例值 Topic string 是 需查询的消息的 Topic。test-mq_topic Key string 是 需查询的消息的 Message Key。messageKey1 ...
OnsMessageDetail-查询消息详细信息
MQ_INST_184681981*_BXig0x6A Topic string 是 需查询的消息的 Topic 名称。test-mq_topic MsgId string 是 需查询的消息的 ID，即 Message ID。1E0578FE110F18B4AAC235C0*返回参数 名称 类型 描述 示例值 object Schema of Response ...
QueryMqSofamqConsumerAccumulate
GroupId String 是 GID_test_consumer_id 需查询的消费端 Group ID InstanceId String 是 MQ_INST_111111111111_DOxxxxxx 实例 ID。针对有独立命名空间的实例，该参数为必填。返回数据 名称 类型 示例值 描述 ResultMessage String OK 结果...
OnsConsumerStatus-查询Group ID消费状态
操作 访问级别 资源类型 条件关键字 关联操作 mq:QueryConsumerStatus Read 全部资源*无 无 请求参数 名称 类型 必填 描述 示例值 GroupId string 是 需要查询的消费端 Group ID。GID_test_group_id Detail boolean 否 是否查询详细信息。...
收发顺序消息
System.out.println(new Date()+"Send mq message success.Topic is:"+topic+",msgId is:"+pubResultMsg.getMessageId()+",bodyMD5 is:"+pubResultMsg.getMessageBodyMD5());} } catch(Throwable e){/消息发送失败，需要进行重试处理，可...
收发定时消息和延时消息
System.out.println(new Date()+"Send mq message success.Topic is:"+topic+",msgId is:"+pubResultMsg.getMessageId()+",bodyMD5 is:"+pubResultMsg.getMessageBodyMD5());} } catch(Throwable e){/消息发送失败，需要进行重试处理，可...
服务关联角色
Action":["mq:PUB","mq:SUB"],"Resource":"acs:mq:*:*:*%TOPIC_TINGWU_*"},{"Action":"ram:DeleteServiceLinkedRole","Resource":"*","Effect":"Allow","Condition":{"StringEquals":{"ram:ServiceName":"tingwupaas.aliyuncs.com" } } } ...
- 产品推荐
- 这些文档可能帮助您