GetAlertMessage-查询报警信息
1234 Topics object[]当 Source（报警来源）为 TOPIC_ALERT（全局事件告警）时，返回触发报警的事件列表。当报警来源为其它类型时，返回结果为空。TopicName string 事件的名称。9527出错 InstanceId long 事件关联的实例 ID。12345 ...
信封交易接口
参数 类型 说明 from Identity 交易结果日志中的字段，代表交易发送者 to Identity 交易结果日志中的字段，代表交易接收者 topics List交易结果日志中的字段，交易执行的事件主题 logData byte[]交易结果日志中的字段，交易执行中的日志...
信封交易接口
参数 类型 说明 from Identity 交易结果日志中的字段，代表交易发送者 to Identity 交易结果日志中的字段，代表交易接收者 topics List交易结果日志中的字段，交易执行的事件主题 logData byte[]交易结果日志中的字段，交易执行中的日志...
alicloud_mns_topic_subscriptions
topic_name-(Required)Two topics on a single account in the same region cannot have the same name.A topic name must start with an English letter or a digit,and can contain English letters,digits,and hyphens,with the length ...
DescribeMetricRuleTargets-查询指定报警规则的推送...
如果资源类型为 topics，则资源名称为主题名称。acs:mns:cn-hangzhou:120886317861*:/queues/test/message Level string 报警级别。取值：INFO：信息。WARN：警告。CRITICAL：紧急。INFO JsonParams string 报警回调的 JSON 格式参数。{...
java_io_IOException
https://developer.android.com/training/permissions/index.html （权限使用文档）...topics/security/permissions.html#normal-dangerous（普通权限及危险权限）https://developer.android.com/training/permissions/requesting.html#perm-check （权限授权方式）
GetBaselineKeyPath-获取基线实例的关键路径
BeginCast":1553531686000,"EndCast":1553531687000,"BeginWaitResTime":1553531401000,"BeginWaitTimeTime":1553531400000 }],"Topics":[{"TopicName":"1234","InstanceId":1234,"TopicId":1234,"AddTime":1553531401000 }]}]} 错误码 ...
签名机制
CanonicalizedResource：表示HTTP所请求资源的URI（统一资源标识符），如消费请求的URI/topics/abc/messages?consumer=GID_abc。说明 用来签名的字符串为UTF-8格式。签名的方法用 RFC 2104 中定义的HMAC-SHA1方法，其中Key为AccessKey ...
查询作业列表
MonitorConf String {"inputs":[{"type":"KAFKA","clusterId":"C-1234567","topics":"kafka_topic","consumer.group":"kafka_consumer_group"}],"outputs":[{"type":"KAFKA","clusterId":"C-1234567","topics":"kafka_topic"}]} 监控配置，...
alicloud_datahub_subscription
The subscription is the basic unit of resource usage in Datahub Service under Publish/Subscribe model.You can manage the relationships between user and topics by using subscriptions.Refer to details.->NOTE:Available since ...
使用Sarama-Kafka-Go实现Kafka消费
kafka-test topics 日志服务Logstore名称。test conf.Net.SASL.User 日志服务Project名称。etl-dev conf.Net.SASL.Password 阿里云账号AccessKey。格式为 {access-key-id}#{access-key-secret}。建议您使用具备日志服务Project写入权限的...
ModifyGroupMonitoringAgentProcess-修改应用分组内的...
如果资源类型为 topics，则资源名称为主题名称。acs:mns:cn-hangzhou:120886317861*:/queues/test/message Level string 否 报警级别。取值：INFO：信息。WARN：警告。CRITICAL：紧急。["INFO","WARN","CRITICAL"]JsonParams string 否 ...
KAFKA指标
KAFKA指标包含以下部分：Kafka-Topics Request TIme Status Request Rate MessageConversion Performance Storage ZK session JVM Throughput Kafka-Home Kafka-Topics 参数 指标 描述 UnderReplicated Kafka_Broker_kafka_cluster_...
CreateDeliveryChannel-创建投递渠道（不推荐）
当投递渠道为 MNS 时，格式为 acs:mns:{RegionId}:{accountId}:/topics/{topicName}，例如：acs:mns:cn-shanghai:100931896542*:/topics/topic1。当投递渠道为 SLS 时，格式为 acs:log:{RegionId}:{accountId}:project/{projectName}/...
CreateGroupMonitoringAgentProcess-创建组进程监控
如果资源类型为 topics，则资源名称为主题名称。acs:mns:cn-hangzhou:120886317861*:/queues/test/message Level string 否 报警级别。取值：INFO：信息。WARN：警告。CRITICAL：紧急。["INFO","WARN","CRITICAL"]JsonParams string 否 ...
alicloud_mns_topic_subscription
(Required,ForceNew)Two topics subscription on a single account in the same topic cannot have the same name.A topic subscription name must start with an English letter or a digit,and can contain English letters,digits,and ...
在Knative上实现Kafka消息推送
alikafka-pre-cn-zv*-1-vpc.alikafka.aliyuncs.com:9092,alikafka-pre-cn-zv*-2-vpc.alikafka.aliyuncs.com:9092,alikafka-pre-cn-zv*-3-vpc.alikafka.aliyuncs.com:9092 topics 创建的Topic的名称。demo-topic 执行以下命令创建...
UpdateDeliveryChannel-更新投递渠道信息（不推荐）
当投递渠道为 MNS 时，格式为 acs:mns:{RegionId}:{accountId}:/topics/{topicName}，例如：acs:mns:cn-shanghai:100931896542*:/topics/topic1。当投递渠道为 SLS 时，格式为 acs:log:{RegionId}:{accountId}:project/{projectName}/...
使用Flume同步EMR Kafka集群的数据至OSS-HDFS服务
kafka-topics.sh-partitions 10-replication-factor 2-zookeeper master-1-1:2181/emr-kafka-topic flume-test-create 生成测试数据。kafka-console-producer.sh-topic flume-test-broker-list master-1-1:9092 例如，输入 abc 并回车。在 ...
作为Input接入
filebeat.inputs:type:kafka hosts:alikafka-pre-cn-zv*-1-vpc.alikafka.aliyuncs.com:9092 - alikafka-pre-cn-zv*-2-vpc.alikafka.aliyuncs.com:9092 - alikafka-pre-cn-zv*-3-vpc.alikafka.aliyuncs.com:9092 topics:["filebeat_test"]...
发送消息API
请求构造 请求行 POST/topics/TopicName/messages?ns=INSTANCE_ID HTTP/1.1 参数说明如下。参数 是否必选 说明 TopicName 是 将消息发送至的Topic名称。ns 否 实例ID，针对有命名空间的新建实例，该参数为必填。是否有命名空间可以在控制台...
教程示例：结合消息服务实现OSS事件通知
步骤四：接收消息 当触发了事件匹配规则时，消息服务将自动创建主题（Topic），Topic名称格式为 mns-en-topics-[Product]-[RuleName]-[Timestamp]，例如 mns-en-topics-oss-notification1-1700098799。此时，您需要为该Topic创建订阅，并在...
ALIYUN:FC:Trigger
Function Type:'ALIYUN:FC:Trigger' Properties:ServiceName:Ref:ServiceName FunctionName:Ref:FunctionName TriggerName:mns TriggerType:mns_topic SourceArn:'Fn:Sub':'acs:mns:${ALIYUN:Region}:${ALIYUN:TenantId}:/topics/${...
DeleteTopic-删除主题
操作 访问级别 资源类型 条件关键字 关联操作 rocketmq:DeleteTopic Write Topic acs:rocketmq:{#regionId}:{#accountId}:instance/{#InstanceId}/topic/{#TopicName} 无 无 请求语法 DELETE/instances/{instanceId}/topics/{topicName} ...
UpdateTopic-更新主题
操作 访问级别 资源类型 条件关键字 关联操作 rocketmq:UpdateTopic Write Topic acs:rocketmq:{#regionId}:{#accountId}:instance/{#InstanceId}/topic/{#TopicName} 无 无 请求语法 PATCH/instances/{instanceId}/topics/{topicName} ...
作为Input接入
logstash_group topics Topic的名称。logstash_test consumer_threads 消费线程数。建议与Topic的分区数保持一致。12 auto_offset_reset 重置偏移量。取值：earliest：读取最早的消息。latest：读取最新的消息。earliest 按 Esc 键回到命令...
查询节点实例详情
MonitorConf String {"inputs":[{"type":"KAFKA","clusterId":"C-1234567","topics":"kafka_topic","consumer.group":"kafka_consumer_group"}],"outputs":[{"type":"KAFKA","clusterId":"C-1234567","topics":"kafka_topic"}]} 监控配置，...
SAE日志导入Kafka最佳实践
elastic_group topics Topic的名称。elastic_test codec 解码的类型。说明 建议设置为JSON格式，与 SAE 日志导入到Kafka的数据格式保持一致。json consumer_threads 消费线程数。说明 建议与Topic的分区数保持一致。12 decorate_events ...
查询PolarDB-X 1.0分布式订阅任务的子任务信息
Topics Map 否["rm_bp15jj3qi1p8f*"]分布式订阅任务下所有的订阅Topic。多个订阅Topic间以英文逗号（,）分隔。说明 本参数和参数 SubMigrationJobIds 两者中至少传入一个。推荐填入参数 SubMigrationJobIds。RegionId String 否 ...
ALIYUN:CMS:MetricRuleTargets
{消息资源类型}：可选择为queues（队列）或者topics（主题）。{资源名称}：队列或主题的名称。返回值 Fn:GetAtt Arns：目标的ARN。Ids：目标ID。示例 YAML 格式 ROSTemplateFormatVersion:'2015-09-01' Parameters:RuleId:Type:String ...
数据库实时导入DataHub
Records"],"Effect":"Allow","Resource":"acs:dhs:*:*:projects/test_ss/topics/*"},{"Action":"ram:CreateServiceLinkedRole","Resource":"*","Effect":"Allow","Condition":{"StringEquals":{"ram:ServiceName":["dwconnection.datahub....
alicloud_datahub_topic
The topic is the basic unit of Datahub data source and is used to define one kind of data or stream.It contains a set of subscriptions.You can manage the datahub source of an application by using topics.Refer to details.->...
作为Input接入
aeN3WLRoMPRXmAP2jvJuGk84Kuuo*"topics:["filebeat_test"]group_id:"filebeat_group"ssl.certificate_authorities:["/home/admin/filebeat/filebeat-7.7.0-linux-x86_64/ca-cert"]ssl.verification_mode:none output.console:pretty:true ...
DescribeGroupMonitoringAgentProcess-获取组进程监控...
如果资源类型为 topics，则资源名称为主题名称。acs:mns:cn-hangzhou:120886317861*:/queues/test/message Level string 报警级别。取值：INFO：信息。WARN：警告。CRITICAL：紧急。CRITICAL JsonParmas string 报警回调的 JSON 格式参数。...
CreateConfigDeliveryChannel-创建投递渠道
当投递渠道为 MNS 时，格式为 acs:mns:{RegionId}:{accountId}:/topics/{topicName}，例如：acs:mns:cn-shanghai:100931896542*:/topics/topic1。当投递渠道为 SLS 时，格式为 acs:log:{RegionId}:{accountId}:project/{projectName}/...
ModifyHostAvailability-修改可用性监控任务
如果资源类型为 topics，则资源名称为主题名称。acs:mns:cn-hangzhou:111:/queues/test/message Level string 否 报警级别。取值：INFO：信息。WARN：警告。CRITICAL：紧急。["INFO","WARN","CRITICAL"]JsonParams string 否 报警回调的 ...
使用JDBC Connector同步MySQL数据
Kafka Connect Consumer Group：Kafka Connect Worker用于消费Internal Topics的消费组，命名规则为 connect-eb-cluster-<任务名称>。Kafka Source Connector Consumer Group：只针对Sink Connector有效，用于消费源Topic中的数据，命名...
UpdateConfigDeliveryChannel-修改投递渠道
当投递渠道为 MNS 时，格式为 acs:mns:{RegionId}:{accountId}:/topics/{topicName}，例如：acs:mns:cn-shanghai:100931896542*:/topics/topic1。当投递渠道为 SLS 时，格式为 acs:log:{RegionId}:{accountId}:project/{projectName}/...
使用JDBC Connector同步MySQL数据
Kafka Connect Consumer Group：Kafka Connect Worker用于消费Internal Topics的消费组，命名规则为 connect-eb-cluster-<任务名称>。Kafka Source Connector Consumer Group：只针对Sink Connector有效，用于消费源Topic中的数据，命名...
通过PyFlink作业处理Kafka数据
kafka-topics.sh-partitions 3-replication-factor 2-bootstrap-server core-1-1:9092-topic payment-msg-create kafka-topics.sh-partitions 3-replication-factor 2-bootstrap-server core-1-1:9092-topic result-create 说明 创建Topic...
- 产品推荐
- 这些文档可能帮助您