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.