DMS
The SDK interfaces based on the DMS v1.0 API are as follows. Invocation example: conn.dms.create_queue()
| Interface | method | API |
| Queue Operations | create_queue(**kwargs) | POST /v1.0/{project_id}/queues |
| queues() | GET /v1.0/{project_id}/queues | |
| get_queue(queue) | GET /v1.0/{project_id}/queues/{queue_id} | |
| delete_queue(queue, ignore_missing=True) | DELETE /v1.0/{project_id}/queues/{queue_id} | |
| Group Operations | create_groups(queue, **kwargs) | POST /v1.0/{project_id}/queues/{queue_id}/groups |
| groups(queue) | GET /v1.0/{project_id}/queues/{queue_id}/groups | |
| delete_group(queue, group) | DELETE /v1.0/{project_id}/queues/{queue_id}/groups/{consumer_group_id} | |
| Message Operations | send_messages(queue, **kwargs) | POST /v1.0/{project_id}/queues/{queue_id}/messages |
| consume_message(queue, consume_group, **query) | GET /v1.0/{project_id}/queues/{queue_id}/groups/{consumer_group_id}/messages | |
| ack_consumed_message(consumed_message, status='success') | POST /v1.0/{project_id}/queues/{queue_id}/groups/{consumer_group_id}/ack | |
| Quota Operations | quotas() | GET /v1.0/{project_id}/quotas/dms |
Did this article solve your problem?
Thank you for your score！Your feedback would help us improve the website.