Interroge la plage de temps dans laquelle vous pouvez spécifier un instant pour réinitialiser l'offset du consommateur pour une rubrique donnée. Cette plage s'étend du premier instant de publication d'un message sur la rubrique au dernier instant de publication.
Remarque
Cette opération permet de connaître le premier et le dernier instant de publication des messages pour une rubrique spécifique. Elle renvoie également le dernier instant auquel un message de cette rubrique a été consommé. En combinant cet appel avec l'opération OnsConsumerAccumulate, vous obtenez une vue complète de la progression de la consommation d'un groupe de consommateurs.
Limites de requêtes
Chaque compte Alibaba Cloud est limité à 10 appels par seconde pour cette opération. Si ce seuil est dépassé, les nouvelles requêtes échouent, ce qui peut perturber vos services. Pour consulter les limites détaillées par opération, reportez-vous aux Limites de requêtes API.
Autorisations
Les comptes Alibaba Cloud disposent des droits nécessaires par défaut. Un utilisateur RAM doit toutefois se voir attribuer les autorisations adéquates avant de pouvoir exécuter cette opération. Le tableau ci-dessous détaille les permissions requises. Pour savoir comment les configurer, consultez la documentation relative aux Stratégies.
|
API |
Action |
Resource in an instance that uses a namespace |
Resource in an instance that does not use a namespace |
|
OnsConsumerTimeSpan |
mq:QueryInstanceBaseInfo mq:QueryConsumerTimeSpan |
acs:mq:::{instanceId}%{topic} |
acs:mq:::{topic} |
Paramètres de requête
|
Parameter |
Type |
Required |
Example |
Description |
|
Action |
String |
Yes |
OnsConsumerTimeSpan |
Nom de l'opération à exécuter. Spécifiez la valeur OnsConsumerTimeSpan. |
|
GroupId |
String |
Yes |
GID_test_group_id |
ID du groupe de consommateurs à interroger. |
|
Topic |
String |
Yes |
test-mq_topic |
Rubrique à laquelle le groupe de consommateurs est abonné. |
|
InstanceId |
String |
Yes |
MQ_INST_111111111111_DOxxxxxx |
ID de l'instance Message Queue for Apache RocketMQ associée au groupe de consommateurs. |
Paramètres de réponse
|
Parameter |
Type |
Example |
Description |
|
RequestId |
String |
A07E3902-B92E-44A6-B6C5-6AA111111**** |
ID de la requête. Généré de manière unique par le système, il facilite le dépannage. |
|
Data |
Object |
Objet contenant les données retournées. |
|
|
MaxTimeStamp |
Long |
1570761026804 |
Premier instant de publication d'un message sur la rubrique. |
|
ConsumeTimeStamp |
Long |
1570761026400 |
Dernier instant de consommation d'un message dans la rubrique. |
|
Topic |
String |
test-mq_topic |
Nom de la rubrique. |
|
MinTimeStamp |
Long |
1570701231122 |
Dernier instant de publication d'un message sur la rubrique. |
|
InstanceId |
String |
MQ_INST_111111111111_DOxxxxxx |
ID de l'instance Message Queue for Apache RocketMQ associée au groupe de consommateurs. |
Exemples
Exemple de requête
http(s)://ons.cn-hangzhou.aliyuncs.com/?Action=OnsConsumerTimeSpan
&GroupId=GID_test_group_id
&InstanceId=MQ_INST_111111111111_DOxxxxxx
&Topic=test-mq_topic
&<Common request parameters>Exemple de réponse en cas de succès
Format XML
HTTP/1.1 200 OK
Content-Type:application/xml
<OnsConsumerTimeSpanResponse>
<Data>
<MinTimeStamp>1570701231122</MinTimeStamp>
<ConsumeTimeStamp>1570761026400</ConsumeTimeStamp>
<InstanceId>MQ_INST_111111111111_DOxxxxxx</InstanceId>
<Topic>test-mq_topic</Topic>
<MaxTimeStamp>1570761026804</MaxTimeStamp>
</Data>
<RequestId>A07E3902-B92E-44A6-B6C5-6AA111111****</RequestId>
</OnsConsumerTimeSpanResponse>Format JSON
HTTP/1.1 200 OK
Content-Type:application/json
{
"Data" : {
"MinTimeStamp" : 1570701231122,
"ConsumeTimeStamp" : 1570761026400,
"InstanceId" : "MQ_INST_111111111111_DOxxxxxx",
"Topic" : "test-mq_topic",
"MaxTimeStamp" : 1570761026804
},
"RequestId" : "A07E3902-B92E-44A6-B6C5-6AA111111****"
}Codes d'erreur
Pour obtenir la liste des codes d'erreur, consultez le Centre d'erreurs API.