--- title: Push Message Batch --- [Skip to content](#_top) [API Reference](https://developers.cloudflare.com/api/python) [Queues](https://developers.cloudflare.com/api/python/resources/queues) [Messages](https://developers.cloudflare.com/api/python/resources/queues/subresources/messages) Copy Markdown Open in **Claude**Open in **ChatGPT**Open in **Cursor** --- **Copy Markdown****View as Markdown** # Push Message Batch queues.messages.bulk\_push(strqueue\_id, MessageBulkPushParams\*\*kwargs) -> [MessageBulkPushResponse]() POST/accounts/{account\_id}/queues/{queue\_id}/messages/batch Pushes a batch of messages to a Queue. ##### Security
API Token The preferred authorization scheme for interacting with the Cloudflare API. Create a token. **Example:**Authorization: Bearer Sn3lZJTBX6kkg7OdcBUAxOO963GEIyGQqnFTOFYY
API Email + API Key The previous authorization scheme for interacting with the Cloudflare API, used in conjunction with a Global API key. **Example:**X-Auth-Email: user@example.com The previous authorization scheme for interacting with the Cloudflare API. When possible, use API tokens instead of Global API keys. **Example:**X-Auth-Key: 144c9defac04969c7bfad8efaa8ea194
##### Accepted Permissions (at least one required) `Queues Write``Workers Scripts Write` ##### ParametersExpand Collapse account\_id: str A Resource identifier. maxLength32 [Link to this property](<#(resource)%20queues.messages%20%3E%20(method)%20bulk_push%20%3E%20(params)%20default%20%3E%20(param)%20account_id%20%3E%20(schema)>) queue\_id: str A Resource identifier. maxLength32 [Link to this property](<#(resource)%20queues.messages%20%3E%20(method)%20bulk_push%20%3E%20(params)%20default%20%3E%20(param)%20queue_id%20%3E%20(schema)>) delay\_seconds: Optional\[float] The number of seconds to wait for attempting to deliver this batch to consumers [Link to this property](<#(resource)%20queues.messages%20%3E%20(method)%20bulk_push%20%3E%20(params)%20default%20%3E%20(param)%20delay_seconds%20%3E%20(schema)>)
messages: Optional\[Iterable\[Message]] One of the following:
class MessageMqQueueMessageText: … body: Optional\[str] Link to this property content\_type: Optional\[Literal\["text"]] Link to this property delay\_seconds: Optional\[float] The number of seconds to wait for attempting to deliver this message to consumers Link to this property
Link to this property
class MessageMqQueueMessageJson: … body: Optional\[object] Link to this property content\_type: Optional\[Literal\["json"]] Link to this property delay\_seconds: Optional\[float] The number of seconds to wait for attempting to deliver this message to consumers Link to this property
Link to this property
[Link to this property](<#(resource)%20queues.messages%20%3E%20(method)%20bulk_push%20%3E%20(params)%20default%20%3E%20(param)%20messages%20%3E%20(schema)>) ##### ReturnsExpand Collapse
class MessageBulkPushResponse: …
metadata: Optional\[Metadata]
metrics: Optional\[MetadataMetrics] Best-effort metrics for the queue. Values may be approximate due to the distributed nature of queues. backlog\_bytes: float The size in bytes of unacknowledged messages in the queue. Link to this property backlog\_count: float The number of unacknowledged messages in the queue. Link to this property oldest\_message\_timestamp\_ms: float Unix timestamp in milliseconds of the oldest unacknowledged message in the queue. Returns 0 if unknown. Link to this property
Link to this property
Link to this property
[Link to this property](<#(resource)%20queues.messages%20%3E%20(model)%20message_bulk_push_response%20%3E%20(schema)>) ### Push Message Batch Python HTTPTypeScriptPythonGoTerraform ``` import os from cloudflare import Cloudflare client = Cloudflare( api_token=os.environ.get("CLOUDFLARE_API_TOKEN"), # This is the default and can be omitted ) response = client.queues.messages.bulk_push( queue_id="023e105f4ecef8ad9ca31a8372d0c353", account_id="023e105f4ecef8ad9ca31a8372d0c353", ) print(response.metadata) ``` 200 example ``` { "errors": [ { "code": 7003, "message": "No route for the URI", "documentation_url": "documentation_url", "source": { "pointer": "pointer" } } ], "messages": [ "string" ], "result": { "metadata": { "metrics": { "backlog_bytes": 1024, "backlog_count": 5, "oldest_message_timestamp_ms": 1710950954154 } } }, "success": true } ``` ##### Returns Examples 200 example ``` { "errors": [ { "code": 7003, "message": "No route for the URI", "documentation_url": "documentation_url", "source": { "pointer": "pointer" } } ], "messages": [ "string" ], "result": { "metadata": { "metrics": { "backlog_bytes": 1024, "backlog_count": 5, "oldest_message_timestamp_ms": 1710950954154 } } }, "success": true } ```