RequestQueueClient

Sub-client for manipulating a single request queue.

Index

Constructors

• __init__

Methods

• add_request
• batch_add_requests
• batch_delete_requests
• delete
• delete_request
• delete_request_lock
• get
• get_request
• list_and_lock_head
• list_head
• list_requests
• prolong_request_lock
• unlock_requests
• update
• update_request

Constructors

__init__

• __init__(args, *, client_key, kwargs): None

• Initialize a new instance.

  ---

  Parameters

  • args: Any

  • keyword-onlyclient_key: str | None = None

  • kwargs: Any

  Returns None

Methods

add_request

• add_request(request, *, forefront): dict

• Add a request to the queue.

  https://docs.apify.com/api/v2#/reference/request-queues/request-collection/add-request

  ---

  Parameters

  • request: dict

  • keyword-onlyforefront: bool | None = None

  Returns dict

batch_add_requests

• batch_add_requests(requests, *, forefront, max_parallel, max_unprocessed_requests_retries, min_delay_between_unprocessed_requests_retries): BatchAddRequestsResult

• Add requests to the request queue in batches.

  Requests are split into batches based on size and processed in parallel.

  https://docs.apify.com/api/v2#/reference/request-queues/batch-request-operations/add-requests

  ---

  Parameters

  • requests: list[dict]

  • keyword-onlyforefront: bool = False

  • keyword-onlymax_parallel: int = 1

  • keyword-onlymax_unprocessed_requests_retries: int | None = None

  • keyword-onlymin_delay_between_unprocessed_requests_retries: timedelta | None = None

  Returns BatchAddRequestsResult

batch_delete_requests

• batch_delete_requests(requests): dict

• Delete given requests from the queue.

  https://docs.apify.com/api/v2#/reference/request-queues/batch-request-operations/delete-requests

  ---

  Parameters

  • requests: list[dict]

  Returns dict

delete

• delete(): None

• Delete the request queue.

  https://docs.apify.com/api/v2#/reference/request-queues/queue/delete-request-queue

  ---

  Returns None

delete_request

• delete_request(request_id): None

• Delete a request from the queue.

  https://docs.apify.com/api/v2#/reference/request-queues/request/delete-request

  ---

  Parameters

  • request_id: str

  Returns None

delete_request_lock

• delete_request_lock(request_id, *, forefront): None

• Delete the lock on a request.

  https://docs.apify.com/api/v2#/reference/request-queues/request-lock/delete-request-lock

  ---

  Parameters

  • request_id: str

  • keyword-onlyforefront: bool | None = None

  Returns None

get

• get(): dict | None

• Retrieve the request queue.

  https://docs.apify.com/api/v2#/reference/request-queues/queue/get-request-queue

  ---

  Returns dict | None

get_request

• get_request(request_id): dict | None

• Retrieve a request from the queue.

  https://docs.apify.com/api/v2#/reference/request-queues/request/get-request

  ---

  Parameters

  • request_id: str

  Returns dict | None

list_and_lock_head

• list_and_lock_head(*, lock_secs, limit): dict

• Retrieve a given number of unlocked requests from the beginning of the queue and lock them for a given time.

  https://docs.apify.com/api/v2#/reference/request-queues/queue-head-with-locks/get-head-and-lock

  ---

  Parameters

  • keyword-onlylock_secs: int

  • keyword-onlylimit: int | None = None

  Returns dict

list_head

• list_head(*, limit): dict

• Retrieve a given number of requests from the beginning of the queue.

  https://docs.apify.com/api/v2#/reference/request-queues/queue-head/get-head

  ---

  Parameters

  • keyword-onlylimit: int | None = None

  Returns dict

list_requests

• list_requests(*, limit, exclusive_start_id): dict

• List requests in the queue.

  https://docs.apify.com/api/v2#/reference/request-queues/request-collection/list-requests

  ---

  Parameters

  • keyword-onlylimit: int | None = None

  • keyword-onlyexclusive_start_id: str | None = None

  Returns dict

prolong_request_lock

• prolong_request_lock(request_id, *, forefront, lock_secs): dict

• Prolong the lock on a request.

  https://docs.apify.com/api/v2#/reference/request-queues/request-lock/prolong-request-lock

  ---

  Parameters

  • request_id: str

  • keyword-onlyforefront: bool | None = None

  • keyword-onlylock_secs: int

  Returns dict

unlock_requests

• unlock_requests(): dict

• Unlock all requests in the queue, which were locked by the same clientKey or from the same Actor run.

  https://docs.apify.com/api/v2#/reference/request-queues/request-collection/unlock-requests

  ---

  Returns dict

  Result of the unlock operation

update

• update(*, name, general_access): dict

• Update the request queue with specified fields.

  https://docs.apify.com/api/v2#/reference/request-queues/queue/update-request-queue

  ---

  Parameters

  • keyword-onlyname: str | None = None

  • keyword-onlygeneral_access: StorageGeneralAccess | None = None

  Returns dict

update_request

• update_request(request, *, forefront): dict

• Update a request in the queue.

  https://docs.apify.com/api/v2#/reference/request-queues/request/update-request

  ---

  Parameters

  • request: dict

  • keyword-onlyforefront: bool | None = None

  Returns dict