8jddlmZddlmZddlmZddlmZmZddl m Z m Z m Z m Z mZmZmZmZddlmZddlmZmZmZmZmZmZmZmZmZmZmZm Z m!Z!m"Z"m#Z#m$Z$m%Z%m&Z&m'Z'm(Z(m)Z)m*Z*m+Z+m,Z,m-Z-m.Z.m/Z/m0Z0m1Z1m2Z2m3Z3m4Z4m5Z5m6Z6m7Z7m8Z8m9Z9m:Z:m;Z;mZ>m?Z?m@Z@mAZAmBZBmCZCmDZDmEZEmFZFmGZGmHZHmIZImJZJddlKmLZLdd lMmNZNdd lOmPZPmQZQmRZRmSZSdd lTmUZUerdd lVmWZWdd lXmYZYddlZm[Z[edGddZ\edGddZ]y)) annotations)cached_property) TYPE_CHECKING)ClientRegistryClientRegistryAsync) API_VERSIONDEFAULT_API_URLDEFAULT_MAX_RETRIES!DEFAULT_MIN_DELAY_BETWEEN_RETRIESDEFAULT_TIMEOUT_LONGDEFAULT_TIMEOUT_MAXDEFAULT_TIMEOUT_MEDIUMDEFAULT_TIMEOUT_SHORT) docs_group)6 ActorClientActorClientAsyncActorCollectionClientActorCollectionClientAsyncActorEnvVarClientActorEnvVarClientAsyncActorEnvVarCollectionClient ActorEnvVarCollectionClientAsyncActorVersionClientActorVersionClientAsyncActorVersionCollectionClient!ActorVersionCollectionClientAsync BuildClientBuildClientAsyncBuildCollectionClientBuildCollectionClientAsync DatasetClientDatasetClientAsyncDatasetCollectionClientDatasetCollectionClientAsyncKeyValueStoreClientKeyValueStoreClientAsyncKeyValueStoreCollectionClient"KeyValueStoreCollectionClientAsync LogClientLogClientAsyncRequestQueueClientRequestQueueClientAsyncRequestQueueCollectionClient!RequestQueueCollectionClientAsync RunClientRunClientAsyncRunCollectionClientRunCollectionClientAsyncScheduleClientScheduleClientAsyncScheduleCollectionClientScheduleCollectionClientAsyncStoreCollectionClientStoreCollectionClientAsync TaskClientTaskClientAsyncTaskCollectionClientTaskCollectionClientAsync UserClientUserClientAsync WebhookClientWebhookClientAsyncWebhookCollectionClientWebhookCollectionClientAsyncWebhookDispatchClientWebhookDispatchClientAsyncWebhookDispatchCollectionClient$WebhookDispatchCollectionClientAsync)ClientStatistics)check_custom_headers) HttpClientHttpClientAsyncImpitHttpClientImpitHttpClientAsync)resolve_compressor) timedelta)HttpCompressor)HttpCompressionAlgorithmzApify API clientsc eZdZdZ d#eeeeeee e ddd d$dZ e d#eed d%dZ ed&dZed'd Zed(d Zd)d Zd*d Zd+d Zd,dZd-dZd.dZd/dZd0dZd1dZd2dZddd3dZd4dZd5dZd6dZ d7dZ!d8dZ"d9dZ#d:dZ$d;dZ%dd!Z(d?d"Z)y)@ ApifyClientaSynchronous client for the Apify API. This is the main entry point for interacting with the Apify platform. It provides methods to access resource-specific sub-clients for managing Actors, runs, datasets, key-value stores, request queues, schedules, webhooks, and more. The client automatically handles retries with exponential backoff for failed or rate-limited requests. ### Usage ```python from apify_client import ApifyClient client = ApifyClient(token='MY-APIFY-TOKEN') # Start an Actor and wait for it to finish. actor_client = client.actor('apify/python-example') run = actor_client.call(run_input={'first_number': 1, 'second_number': 2}) # Fetch results from the run's default dataset. if run is not None: dataset_client = client.dataset(run.default_dataset_id) items = dataset_client.list_items().items for item in items: print(item) ``` Ngzip api_urlapi_public_url max_retriesmin_delay_between_retries timeout_shorttimeout_medium timeout_long timeout_maxheaders compressionc J|tn|}|tn|}| r t|jj| ||_ |j ddt |_ |j ddt |_ t|_ d|_ tdidtdtdtdt dt"dt$d t&d t(d t*d t,d t.dt0dt2dt4dt6dt8dt:dt<dt>dt@dtBdtDdtFdtHdtJdtLdtN|_( ||_)||_*||_+||_,||_-| |_.| |_/ta| |_1yaInitialize the Apify API client. To use a custom HTTP client, use the `with_custom_http_client` class method instead. Args: token: The Apify API token. You can find your token on the [Integrations](https://console.apify.com/account/integrations) page in the Apify Console. api_url: The URL of the Apify API server to connect to. Defaults to https://api.apify.com. It can be an internal URL that is not globally accessible, in which case `api_public_url` should be set as well. api_public_url: The globally accessible URL of the Apify API server. Should be set only if `api_url` is an internal URL that is not globally accessible. Defaults to https://api.apify.com. max_retries: How many times to retry a failed request at most. min_delay_between_retries: How long will the client wait between retrying requests (increases exponentially from this value). timeout_short: Default timeout for short-duration API operations (simple CRUD operations, ...). timeout_medium: Default timeout for medium-duration API operations (batch operations, listing, ...). timeout_long: Default timeout for long-duration API operations (long-polling, streaming, ...). timeout_max: Maximum timeout cap for any single request attempt, including tier and per-call timeouts. headers: Additional HTTP headers to include in all API requests. compression: Compression algorithm for request bodies. Pass a string literal to select an algorithm, or an `HttpCompressor` instance for finer-grained control. N/ actor_clientactor_collection_clientactor_env_var_clientactor_env_var_collection_clientactor_version_clientactor_version_collection_client build_clientbuild_collection_clientdataset_clientdataset_collection_clientkey_value_store_client!key_value_store_collection_client log_clientrequest_queue_clientrequest_queue_collection_client run_clientrun_collection_clientschedule_clientschedule_collection_clientstore_collection_client task_clienttask_collection_client user_clientwebhook_clientwebhook_collection_clientwebhook_dispatch_client"webhook_dispatch_collection_client)2r rH __class____name___tokenrstripr _base_url_public_base_urlrG _statistics _http_clientrrrrrrrrrr!r#r%r'r)r+r-r/r1r3r5r7r9r;r=r?rArCrE_client_registry _max_retries_min_delay_between_retries_timeout_short_timeout_medium _timeout_long _timeout_max_headersrM_http_compressor selftokenrUrVrWrXrYrZr[r\r]r^s Q/var/www/html/GAP/venv/lib/python3.12/site-packages/apify_client/_apify_client.py__init__zApifyClient.__init__tsN&-_/',:,B  !8!8' B 1#NN3/0+?(#1#8#8#=">a } M-+-6/3e .! $! $9! "3! -H ! "4 ! -I ! %! %:! )! '>! $7! /L! !! "4! -I! !!! "#6#! $+%! &(@'! (%:)! *#+! ,$8-! .#/! 0)1! 2'>3! 4%:5! 60O7! : Q(*C'+-)' 2; ?rUrVcP||||}||j|||_|S)a8Create an `ApifyClient` instance with a custom HTTP client. Use this alternative constructor when you want to provide your own HTTP client implementation instead of the default one. The custom client controls its transport configuration; the shared `HttpClient` pipeline handles request preparation, retries, timeouts, and API errors unless overridden. ### Usage ```python from apify_client import ApifyClient from apify_client.http_clients import HttpClient, HttpResponse class MyHttpClient(HttpClient): def send_request(self, *, method, url, headers, content, timeout, stream) -> HttpResponse: ... client = ApifyClient.with_custom_http_client( token='MY-APIFY-TOKEN', http_client=MyHttpClient(), ) ``` Args: token: The Apify API token. It is set as the `Authorization` header on the custom client, unless the client already has one configured. api_url: The URL of the Apify API server to connect to. Defaults to https://api.apify.com. api_public_url: The globally accessible URL of the Apify API server. Defaults to https://api.apify.com. http_client: A custom HTTP client instance extending `HttpClient`. rrUrVset_default_authorizationrclsrrUrV http_clientinstances rwith_custom_http_clientz#ApifyClient.with_custom_http_client4PUGNS    1 1% 8 +rc|jSz'The Apify API token used by the client.rrs rrzApifyClient.token{{rc .|j~t|j|j|j|j |j |j|j|j|j|j |_|jS)zThe HTTP client instance used for API communication. Returns the custom HTTP client if one was provided via `with_custom_http_client`, or the default `ImpitHttpClient` otherwise (lazily created on first access). rrYrZr[r\rWrX statisticsr]http_compressor) rrKrrrrrrrrrrrs rrzApifyClient.http_client s    $ /kk"11#33!// -- --*.*I*I++ $ 5 5 !D    rc`|j|j|j|jdSz8Base keyword arguments for resource client construction.)base_urlpublic_base_urlrclient_registryrrrrrs r _base_kwargszApifyClient._base_kwargs#0#44++#44   rc0tdd|i|jSzyGet the sub-client for a specific Actor. Args: actor_id: ID of the Actor to be manipulated. resource_idr})rrractor_ids ractorzApifyClient.actor- ExE43D3DEErc,tdi|jSzPGet the sub-client for the Actor collection, allowing to list and create Actors.r})rrrs ractorszApifyClient.actors5$9t'8'899rc0tdd|i|jSzGet the sub-client for a specific Actor build. Args: build_id: ID of the Actor build to be manipulated. rr})rrrbuild_ids rbuildzApifyClient.build9rrc,tdi|jSzEGet the sub-client for the build collection, allowing to list builds.r})rrrs rbuildszApifyClient.buildsArrc0tdd|i|jSzGet the sub-client for a specific Actor run. Args: run_id: ID of the Actor run to be manipulated. rr})r/rrrun_ids rrunzApifyClient.runEs AVAt/@/@AArc,tdi|jSzGGet the sub-client for the run collection, allowing to list Actor runs.r})r1rrs rrunszApifyClient.runsMs"7T%6%677rc0tdd|i|jSzGet the sub-client for a specific dataset. Args: dataset_id: ID of the dataset to be manipulated. rr})r!rr dataset_ids rdatasetzApifyClient.datasetQ IIt7H7HIIrc,tdi|jSzTGet the sub-client for the dataset collection, allowing to list and create datasets.r})r#rrs rdatasetszApifyClient.datasetsY&;):):;;rc0tdd|i|jSzGet the sub-client for a specific key-value store. Args: key_value_store_id: ID of the key-value store to be manipulated. rr})r%rrkey_value_store_ids rkey_value_storezApifyClient.key_value_store]s #W/AWTEVEVWWrc,tdi|jSzdGet the sub-client for the key-value store collection, allowing to list and create key-value stores.r})r'rrs rkey_value_storeszApifyClient.key_value_storese,At/@/@AAr client_keyc2td||d|jSzGet the sub-client for a specific request queue. Args: request_queue_id: ID of the request queue to be manipulated. client_key: A unique identifier of the client accessing the request queue. )rrr})r+rrrequest_queue_idrs r request_queuezApifyClient.request_queueis!"k.>:kY]YjYjkkrc,tdi|jSz`Get the sub-client for the request queue collection, allowing to list and create request queues.r})r-rrs rrequest_queueszApifyClient.request_queuesr+@d.?.?@@rc0tdd|i|jSzGet the sub-client for a specific webhook. Args: webhook_id: ID of the webhook to be manipulated. rr})r?rr webhook_ids rwebhookzApifyClient.webhookvrrc,tdi|jSzTGet the sub-client for the webhook collection, allowing to list and create webhooks.r})rArrs rwebhookszApifyClient.webhooks~rrc0tdd|i|jSzGet the sub-client for a specific webhook dispatch. Args: webhook_dispatch_id: ID of the webhook dispatch to access. rr})rCrrwebhook_dispatch_ids rwebhook_dispatchzApifyClient.webhook_dispatchs %Z1DZHYHYZZrc,tdi|jSz\Get the sub-client for the webhook dispatch collection, allowing to list webhook dispatches.r})rErrs rwebhook_dispatcheszApifyClient.webhook_dispatchess.C1B1BCCrc0tdd|i|jSzGet the sub-client for a specific schedule. Args: schedule_id: ID of the schedule to be manipulated. rr})r3rr schedule_ids rschedulezApifyClient.schedules K+K9J9JKKrc,tdi|jSzVGet the sub-client for the schedule collection, allowing to list and create schedules.r})r5rrs r scheduleszApifyClient.schedules'<$*;*;<d!Z(d?d"Z)y)@ApifyClientAsyncaVAsynchronous client for the Apify API. This is the main entry point for interacting with the Apify platform using async/await. It provides methods to access resource-specific sub-clients for managing Actors, runs, datasets, key-value stores, request queues, schedules, webhooks, and more. The client automatically handles retries with exponential backoff for failed or rate-limited requests. ### Usage ```python import asyncio from apify_client import ApifyClientAsync async def main() -> None: client = ApifyClientAsync(token='MY-APIFY-TOKEN') # Start an Actor and wait for it to finish. actor_client = client.actor('apify/python-example') run = await actor_client.call(run_input={'first_number': 1, 'second_number': 2}) # Fetch results from the run's default dataset. if run is not None: dataset_client = client.dataset(run.default_dataset_id) items = (await dataset_client.list_items()).items for item in items: print(item) asyncio.run(main()) ``` NrSrTc J|tn|}|tn|}| r t|jj| ||_ |j ddt |_ |j ddt |_ t|_ d|_ tdidtdtdtdt dt"dt$d t&d t(d t*d t,d t.dt0dt2dt4dt6dt8dt:dt<dt>dt@dtBdtDdtFdtHdtJdtLdtN|_( ||_)||_*||_+||_,||_-| |_.| |_/ta| |_1yr`)2r rHr~rrrrrrrGrrrrrrrrrrr r"r$r&r(r*r,r.r0r2r4r6r8r:r<r>r@rBrDrFrrrrrrrrrMrrs rrzApifyClientAsync.__init__sN&-_/',:,B  !8!8' B 1#NN3/0+?(#1#8#8#=">a } M-+-648e 3! )! $>! "8! -M ! "9 ! -N ! *! %?! .! 'C! $<! /Q! &! "9! -N! &!! "#;#! $0%! &(E'! (%?)! *(+! ,$=-! .(/! 0.1! 2'C3! 4%?5! 60T7! : Q(*C'+-)' 2; ?rrcP||||}||j|||_|S)akCreate an `ApifyClientAsync` instance with a custom HTTP client. Use this alternative constructor when you want to provide your own HTTP client implementation instead of the default one. The custom client controls its transport configuration; the shared `HttpClientAsync` pipeline handles request preparation, retries, timeouts, and API errors unless overridden. ### Usage ```python from apify_client import ApifyClientAsync from apify_client.http_clients import HttpClientAsync, HttpResponse class MyHttpClientAsync(HttpClientAsync): async def send_request(self, *, method, url, headers, content, timeout, stream) -> HttpResponse: ... client = ApifyClientAsync.with_custom_http_client( token='MY-APIFY-TOKEN', http_client=MyHttpClientAsync(), ) ``` Args: token: The Apify API token. It is set as the `Authorization` header on the custom client, unless the client already has one configured. api_url: The URL of the Apify API server to connect to. Defaults to https://api.apify.com. api_public_url: The globally accessible URL of the Apify API server. Defaults to https://api.apify.com. http_client: A custom HTTP client instance extending `HttpClientAsync`. rrrs rrz(ApifyClientAsync.with_custom_http_clientErrc|jSrrrs rrzApifyClientAsync.tokensrrc .|j~t|j|j|j|j |j |j|j|j|j|j |_|jS)zThe HTTP client instance used for API communication. Returns the custom HTTP client if one was provided via `with_custom_http_client`, or the default `ImpitHttpClientAsync` otherwise (lazily created on first access). r) rrLrrrrrrrrrrrs rrzApifyClientAsync.http_clientxs    $ 4kk"11#33!// -- --*.*I*I++ $ 5 5 !D    rc`|j|j|j|jdSrrrs rrzApifyClientAsync._base_kwargsrrc0tdd|i|jSr)rrrs rrzApifyClientAsync.actor  JHJ8I8IJJrc,tdi|jSr)rrrs rrzApifyClientAsync.actors)>D,=,=>>rc0tdd|i|jSr)rrrs rrzApifyClientAsync.buildr1rc,tdi|jSr)r rrs rrzApifyClientAsync.buildsr3rc0tdd|i|jSr)r0rrs rrzApifyClientAsync.runs F&FD4E4EFFrc,tdi|jSr)r2rrs rrzApifyClientAsync.runsrrc0tdd|i|jSr)r"rrs rrzApifyClientAsync.dataset "NjNDO>OPPrc,tdi|jSr)r6rrs rrzApifyClientAsync.schedulesrrc0tdd|i|jSr)r*rrs rrzApifyClientAsync.logs O/OT=N=NOOrc0tdd|i|jSr )r:rr s rr zApifyClientAsync.task  H7Hd6G6GHHrc,tdi|jSr)r<rrs rrzApifyClientAsync.taskss(=4+<+<==rc0tdd|i|jSr)r>rrs rrzApifyClientAsync.userrGrc,tdi|jSr)r8rrs rrzApifyClientAsync.store!r3rrr) rrrUrrVrrrJrr*r )rrJr!)rrrr)rr)rrrr)rr )rrrr0)rr2)rrrr")rr$)rrrr&)rr()rrrrrr,)rr.)rrrr@)rrB)rrrrD)rrF)rrrr4)rr6)rrrr*)r rrr:)rr<)rrrr>)rr8r#r}rrr*r*s!J!c@'%4./P#8$:"6!4)-AGc@c@ c@ # c@  c@$-c@!c@"c@ c@c@'c@?c@ c@J!+'%4 ++ + # + % + ++Z!!*  K?K?G=OA]GPTqFOA`IQBPI>I?rr*N)^ __future__r functoolsrtypingrapify_client._client_registryrrapify_client._constsrr r r r r rrapify_client._docsrapify_client._resource_clientsrrrrrrrrrrrrrrrr r!r"r#r$r%r&r'r(r)r*r+r,r-r.r/r0r1r2r3r4r5r6r7r8r9r:r;r<r=r>r?r@rArBrCrDrErFapify_client._statisticsrGapify_client._utils.httprHapify_client.http_clientsrIrJrKrL&apify_client.http_compressors._resolverMdatetimerN#apify_client.http_compressors._baserOapify_client.typesrPrRr*r}rrrYs"% M   *77777777777777p69hhE"B;  a:a:!a:H   g?g?!g?r