(ph~  SrSSKrSSKrSSKrSSKJr SSKJr SSKrSSKrSSK r SSK r SSK J r SSK Jr SSK Jr SSK Jr SS K Jr SS K Jr SSKrSS KJr SS KJr SS KJr SSKJr SSKJr SSKJr SSKJr SSKJr SSKJ r SSKJ!r! SSKJ"r" SSKJ#r# SSK$J%r% SSK&J'r' SSK&J(r( SSK&J)r) SSK&J*r* SSK&J+r+ SSK&J,r, SSK&J-r- SSK&J.r. SS K/J0r0 SS!K/J1r1 SS"K&J2r2 SS#K&J3r3 SS$K4J5r5 SS%K6J7r7 SS&K6J8r8 SS'K9J:r: SS(K9J;r; SS)K9Jr> SS,K9J?r? SS-K9J@r@ SS.KAJBrB SS/KAJCrC SS0KDJErE SS1KDJFrF SS2KDJGrG SS3KDJHrH SS4KIJJrJ SS5KIJKrK S6rLS7rMS8rN\NS9-rO\NS:-rPS;rQSS?\QS@SASBSCSDSESF4 rRSGrSSHrTSIrUSJrVSKrWSLrXSMrYSNrZ\ R"SO5r\SPr]SQr^\R"\`5ra"SRSS\)5rbSTrcS\SUjrdS]SVjreS\SWjrfSXrgSYrh"SZS[\i5rjg)^z3Create / interact with Google Cloud Storage blobs. N)BytesIO) TextIOWrapper) HeaderParser) parse_qsl)quote) urlencode)urlsplit) urlunsplit)ChunkedDownload)Download) RawDownload)RawChunkedDownload)MultipartUpload)ResumableUpload)Policy) exceptions)_bytes_to_unicode)_datetime_to_rfc3339)_rfc3339_nanos_to_datetime) _to_bytes)NotFound)_add_etag_match_headers) _add_generation_match_parameters)_PropertyMixin)_scalar_property)_bucket_bound_hostname_url)_raise_if_more_than_one_set)_get_default_headers)_get_default_storage_base_url)generate_signed_url_v2)generate_signed_url_v4) _API_VERSION)_virtual_hosted_style_base_url)create_trace_span)ACL) ObjectACL)_DEFAULT_TIMEOUT)ARCHIVE_STORAGE_CLASS)COLDLINE_STORAGE_CLASS)#MULTI_REGIONAL_LEGACY_STORAGE_CLASS)NEARLINE_STORAGE_CLASS)REGIONAL_LEGACY_STORAGE_CLASS)STANDARD_STORAGE_CLASS)DataCorruption)InvalidResponse)ConditionalRetryPolicy) DEFAULT_RETRY)DEFAULT_RETRY_IF_ETAG_IN_JSON)%DEFAULT_RETRY_IF_GENERATION_SPECIFIED) BlobReader) BlobWriterzapplication/octet-streamz9{hostname}/download/storage/{api_version}{path}?alt=mediazB{hostname}/upload/storage/{api_version}{bucket_path}/o?uploadType= multipart resumable contentType cacheControlcontentDispositioncontentEncodingcontentLanguagecrc32c customTimemd5Hashmetadataname retention storageClasszOSize {:d} was specified but the file-like object only had {:d} bytes remaining.znA checksum of type `{}` was requested, but checksumming is not available for downloads when chunk_size is set.z'if_generation_match: type list' is deprecated and supported for backwards-compatability reasons only. Use 'if_source_generation_match' instead' to match source objects' generations.zUse 'if_generation_match' to match the generation of the destination object by passing in a generation number, instead of a list. Use 'if_source_generation_match' to match source objects generations.z'if_metageneration_match: type list' is deprecated and supported for backwards-compatability reasons only. Note that the metageneration to be matched is that of the destination blob. Please pass in a single value (type long).zH'if_source_generation_match' length must be the same as 'sources' lengthzlBlob.download_as_string() is deprecated and will be removed in future. Use Blob.download_as_bytes() instead.z\Blob.from_string() is deprecated and will be removed in future. Use Blob.from_uri() instead.zB(?Pgs)://(?P[a-z0-9_.-]+)/(?P.+)i@ic$^\rSrSrSrSrSr\\\ \ \ \ 4r S]U4Sjjr\S5r\S5r\R$S5r\S 5r\R$S 5r\S 5r\S 5rS r\S5r\S5r\S5rSr\S5r\S5r\S^Sj5r\S^Sj5r S_Sjr!SSSSSSS\"\#S4 Sjr$SSSSS\"\#4Sjr%Sr&S]Sjr'Sr(SSS\"S\#4Sjr)SSSSSSSSSS\"S\#4 Sjr*S r+SSSSSSSSSS\"S\#4 S!jr,SSSSSSSSSS\"S\#4 S"jr-SSSSSSSSSS\"\#4 S#jr.SSSSSSSSSSS\"\#4 S$jr/S^S%jr0S&r1S`S'jr2\"SSS4S(jr3SSSSSSS\"SSS4 S)jr4\"SSS4S*jr5\"SSS4S+jr6SSSSSSSSS\"S\#S4 S,jr7SSSSSSSSS\"S\#4 S-jr8S^S.jr9SSSSSSS\"S\#4 S/jr:S0SSSSSS\"S\#4 S1jr;SSSS\"SSSSSS\#4 S2jr4S4jr?S\"\#4S5jr@S\"SSSS\#4S6jrAS\"SSSS\#4S7jrBS\"SSS\C4S8jrDSSSSSSSSSS\"\C4 S9jrESSSSSSSSS\"\C4 S:jrFSaS;jrG\H"S<5rI\H"S=5rJ\H"S>5rK\H"S?5rL\H"\M5rN\H"S@5rOSSSSSSSSSS\"S\#S4SAjrP\SB5rQ\SC5rR\H"SD5rS\SE5rT\SF5rU\H"SG5rV\SH5rW\SI5rX\XR$SJ5rX\SK5rY\SL5rZ\SM5r[\SN5r\\SO5r]\SP5r^\^R$SQ5r^\H"SR5r_\H"SS5r`\ST5ra\SU5rb\SV5rc\SW5rd\dR$SX5rd\SY5re\SZ5rf\S[5rgS\rhU=ri$)bBlobaA wrapper around Cloud Storage's concept of an ``Object``. :type name: str :param name: The name of the blob. This corresponds to the unique path of the object in the bucket. If bytes, will be converted to a unicode object. Blob / object names can contain any sequence of valid unicode characters, of length 1-1024 bytes when UTF-8 encoded. :type bucket: :class:`google.cloud.storage.bucket.Bucket` :param bucket: The bucket to which this blob belongs. :type chunk_size: int :param chunk_size: (Optional) The size of a chunk of data whenever iterating (in bytes). This must be a multiple of 256 KB per the API specification. If not specified, the chunk_size of the blob itself is used. If that is not specified, a default value of 40 MB is used. :type encryption_key: bytes :param encryption_key: (Optional) 32 byte encryption key for customer-supplied encryption. See https://cloud.google.com/storage/docs/encryption#customer-supplied. :type kms_key_name: str :param kms_key_name: (Optional) Resource name of Cloud KMS key used to encrypt the blob's contents. :type generation: long :param generation: (Optional) If present, selects a specific revision of this object. Nic>[U5n[[U]US9 X0lX l[ U5Ul[XES9 X@l UbXPRS'UbX`RS'gg)z0 property :attr:`name` Get the blob's name. rA)encryption_key kms_key_nameN kmsKeyName generation) rsuperrE__init__ chunk_size_bucketr&_aclr_encryption_key _properties)selfrAbucketrOrIrJrL __class__s L/var/www/html/venv/lib/python3.13/site-packages/google/cloud/storage/blob.pyrN Blob.__init__sv!& dD""-$ dO #)  .  #-9  \ *  !-7  \ * "cUR$)zwBucket which contains the object. :rtype: :class:`~google.cloud.storage.bucket.Bucket` :returns: The object's bucket. )rPrTs rWrU Blob.buckets||rYcUR$)zwGet the blob's default chunk size. :rtype: int or ``NoneType`` :returns: The current blob's chunk size, if it is set. ) _chunk_sizer[s rWrOBlob.chunk_sizesrYcxUb1US:a+XR-S:wa[SUR4-5eXlg)zSet the blob's default chunk size. :type value: int :param value: (Optional) The current blob's chunk size, if it is set. :raises: :class:`ValueError` if ``value`` is not ``None`` and is not a multiple of 256 KB. Nrz$Chunk size must be a multiple of %d.)_CHUNK_SIZE_MULTIPLE ValueErrorr^rTvalues rWrOr_sG  u7P7P/PTU/U6$:S:S9UU !rYcUR$)zRetrieve the customer-supplied encryption key for the object. :rtype: bytes or ``NoneType`` :returns: The encryption key or ``None`` if no customer-supplied encryption key was used, or the blob's resource has not been loaded from the server. rRr[s rWrIBlob.encryption_keys###rYcXlg)ajSet the blob's encryption key. See https://cloud.google.com/storage/docs/encryption#customer-supplied To perform a key rotation for an encrypted blob, use :meth:`rewrite`. See https://cloud.google.com/storage/docs/encryption/using-customer-supplied-keys?hl=ca#rotating :type value: bytes :param value: 32 byte encryption key for customer-supplied encryption. Nrfrcs rWrIrgs  %rYc$US-[U5-$)zRelative URL path for a blob. :type bucket_path: str :param bucket_path: The URL path for a bucket. :type blob_name: str :param blob_name: The name of the blob. :rtype: str :returns: The relative URL path for ``blob_name``. z/o/)_quote) bucket_path blob_names rW path_helperBlob.path_helper+sU"VI%666rYcUR$)zCreate our ACL on demand.)rQr[s rWaclBlob.acl:syyrYcUR(aURRnOSnSUSURSURS3$)Nz)rUrArL)rT bucket_names rW__repr__ Blob.__repr__?sA ;;++**KK R {"T__4EQGGrYcUR(d [S5eURURRUR5$)zaGetter property for the URL path to this Blob. :rtype: str :returns: The URL path to this Blob. z*Cannot determine path without a blob name.)rArbrmrUpathr[s rWrx Blob.pathGs8yyIJ J 0 0$))<.storage.googleapis.com'. Incompatible with bucket_bound_hostname. :type bucket_bound_hostname: str :param bucket_bound_hostname: (Optional) If passed, then construct the URL relative to the bucket-bound hostname. Value can be a bare or with scheme, e.g., 'example.com' or 'http://example.com'. Incompatible with api_access_endpoint and virtual_hosted_style. See: https://cloud.google.com/storage/docs/request-endpoints#cname :type scheme: str :param scheme: (Optional) If ``bucket_bound_hostname`` is passed as a bare hostname, use this value as the scheme. ``https`` will work only when using a CDN. Defaults to ``"http"``. :raises: :exc:`ValueError` when version is invalid or mutually exclusive arguments are used. :raises: :exc:`TypeError` when expiration is not a valid type. :raises: :exc:`AttributeError` if credentials is not an instance of :class:`google.auth.credentials.Signing`. :rtype: str :returns: A signed URL you can use to access the resource until expiration. v2)rv4z%'version' must be either 'v2' or 'v4'zmThe bucket_bound_hostname argument is not compatible with either api_access_endpoint or virtual_hosted_style.rr/zX-Goog-Encryption-Algorithm)resource expirationapi_access_endpointmethod content_md5 content_type response_typeresponse_dispositionrLheadersquery_parametersservice_account_email access_tokenuniverse_domain)rb_require_clientrrjrAr#rUr _credentialsrr r!rRrupdateupper)rTrrrrrrrrLrrr{ credentialsversionrrvirtual_hosted_stylebucket_bound_hostnameschemerrrhelperencryption_headers v2_copy_onlys rWgenerate_signed_urlBlob.generate_signed_urlsl ?G L (DE E +/C#F   &))&1F"("5"5 TYYU3 "@#[[%5%5# ;-(H ""<%v# ;-(H4;;++,Ak];H  ))&1F --K%%f- 00 d?+F+F    +!89M9M!N $< (:<(H %12 ! 3<<>#%'!5!-"7%+  rYc @[SS9 URU5nURn SU S'U bXS'[U UUUUS9 0n [ U UUS9 UR UR U U UU SS 9 SSS5 g ![a SSS5 g f=f!,(df  g=f) aDetermines whether or not this blob exists. If :attr:`user_project` is set on the bucket, bills the API request to that project. :type client: :class:`~google.cloud.storage.client.Client` :param client: (Optional) The client to use. If not passed, falls back to the ``client`` stored on the blob's bucket. :type if_etag_match: Union[str, Set[str]] :param if_etag_match: (Optional) See :ref:`using-if-etag-match` :type if_etag_not_match: Union[str, Set[str]] :param if_etag_not_match: (Optional) See :ref:`using-if-etag-not-match` :type if_generation_match: long :param if_generation_match: (Optional) See :ref:`using-if-generation-match` :type if_generation_not_match: long :param if_generation_not_match: (Optional) See :ref:`using-if-generation-not-match` :type if_metageneration_match: long :param if_metageneration_match: (Optional) See :ref:`using-if-metageneration-match` :type if_metageneration_not_match: long :param if_metageneration_not_match: (Optional) See :ref:`using-if-metageneration-not-match` :type timeout: float or tuple :param timeout: (Optional) The amount of time, in seconds, to wait for the server response. See: :ref:`configuring_timeouts` :type retry: google.api_core.retry.Retry or google.cloud.storage.retry.ConditionalRetryPolicy :param retry: (Optional) How to retry the RPC. See: :ref:`configuring_retries` :type soft_deleted: bool :param soft_deleted: (Optional) If True, looks for a soft-deleted object. Will only return True if the object exists and is in a soft-deleted state. :attr:`generation` is required to be set on the blob if ``soft_deleted`` is set to True. See: https://cloud.google.com/storage/docs/soft-delete :rtype: bool :returns: True if the blob exists in Cloud Storage. zStorage.Blob.existsrHrAfieldsN softDeletedif_generation_matchif_generation_not_matchif_metageneration_matchif_metageneration_not_match if_etag_matchif_etag_not_match query_paramsrtimeoutretry_target_objectFT)r$rrrr _get_resourcerxr) rTr{rrrrrrrr soft_deletedrrs rWexists Blob.existssD$9 :))&1F --L%+L "'.:]+ ,$7(?(?,G  G #+"3   $$II!-###' %Q; :F O; :F G; :s0ABA7-B7 B B B  B Bc [SS9 URRURUURUUUUUUS9 SSS5 g!,(df  g=f)aDeletes a blob from Cloud Storage. If :attr:`user_project` is set on the bucket, bills the API request to that project. :type client: :class:`~google.cloud.storage.client.Client` :param client: (Optional) The client to use. If not passed, falls back to the ``client`` stored on the blob's bucket. :type if_generation_match: long :param if_generation_match: (Optional) See :ref:`using-if-generation-match` :type if_generation_not_match: long :param if_generation_not_match: (Optional) See :ref:`using-if-generation-not-match` :type if_metageneration_match: long :param if_metageneration_match: (Optional) See :ref:`using-if-metageneration-match` :type if_metageneration_not_match: long :param if_metageneration_not_match: (Optional) See :ref:`using-if-metageneration-not-match` :type timeout: float or tuple :param timeout: (Optional) The amount of time, in seconds, to wait for the server response. See: :ref:`configuring_timeouts` :type retry: google.api_core.retry.Retry or google.cloud.storage.retry.ConditionalRetryPolicy :param retry: (Optional) How to retry the RPC. A None value will disable retries. A google.api_core.retry.Retry value will enable retries, and the object will define retriable response codes and errors and configure backoff and timeout options. A google.cloud.storage.retry.ConditionalRetryPolicy value wraps a Retry object and activates it only if certain conditions are met. This class exists to provide safe defaults for RPC calls that are not technically safe to retry normally (due to potential data duplication or other side-effects) but become safe to retry if a condition such as if_generation_match is set. See the retry.py source code and docstrings in this package (google.cloud.storage.retry) for information on retry types and how to configure them. :raises: :class:`google.cloud.exceptions.NotFound` (propagated from :meth:`google.cloud.storage.bucket.Bucket.delete_blob`). zStorage.Blob.deleterH)r{rLrrrrrrN)r$rU delete_blobrArL)rTr{rrrrrrs rWdelete Blob.deletesT|$9 : KK # # ??$7(?(?,G $ ; : :s 6A  Ac<URU5nUR$)aReturn the client's transport. :type client: :class:`~google.cloud.storage.client.Client` :param client: (Optional) The client to use. If not passed, falls back to the ``client`` stored on the blob's bucket. :rtype transport: :class:`~google.auth.transport.requests.AuthorizedSession` :returns: The transport (with credentials) that will make authenticated requests. )r_http)rTr{s rW_get_transportBlob._get_transport]s%%f-||rYc/nURcd[UR5n[R XpR [ S9nURbURSURS45 O URnURbURSUR45 [UUUUUS9 [X5$)ahGet the download URL for the current blob. If the ``media_link`` has been loaded, it will be used, otherwise the URL will be constructed from the current blob's path (and possibly generation) to avoid a round trip. :type client: :class:`~google.cloud.storage.client.Client` :param client: The client to use. :type if_generation_match: long :param if_generation_match: (Optional) See :ref:`using-if-generation-match` :type if_generation_not_match: long :param if_generation_not_match: (Optional) See :ref:`using-if-generation-not-match` :type if_metageneration_match: long :param if_metageneration_match: (Optional) See :ref:`using-if-metageneration-match` :type if_metageneration_not_match: long :param if_metageneration_not_match: (Optional) See :ref:`using-if-metageneration-not-match` :rtype: str :returns: The download URL for the current blob. )hostnamerx api_versionrLdrr) media_link_get_host_name _connection_DOWNLOAD_URL_TEMPLATErrxr"rLappendr~r_add_query_parameters) rTr{rrrrname_value_pairsrbase_urls rW_get_download_urlBlob._get_download_urlmsH ?? "%f&8&89H-44! |5H* ''$//!9L(NOH    (  # #]D4E4E$F G(  3$;$;(C  %X@@rYcURRSS5URS'URRSS5UR['URRSS5URS'URRSS5URS'URRS S5URS 'URRS S5URS 'URRS S5URS'URRSS5URS'URRSS5nU(a0nUR S5H9n[ R "SU5nU(dM#UR5upgXsU'M; URSS5URS'URSS5URS'gg)aExtract headers from a non-chunked request's http object. This avoids the need to make a second request for commonly used headers. :type response: :class requests.models.Response :param response: The server response from downloading a non-chunked file zContent-EncodingNr;z Content-Typez Cache-Controlr9zX-Goog-Storage-ClassrCzContent-Languager<ETagetagzX-goog-generationrLzX-goog-metagenerationmetagenerationz X-Goog-Hash,z (crc32c|md5)=([\w\d/\+/]+={0,3})r=md5r?)rgetrS_CONTENT_TYPE_FIELDsplitrergroups)rTresponse x_goog_hashdigestsencoded_digestrrdigests rW_extract_headers_from_download#Blob._extract_headers_from_downloads/7.>.>.B.B / *+190@0@0D0D D1 ,-,4+;+;+?+?QU+V(+3+;+;+?+? "D, (/7.>.>.B.B / *+$,#3#3#7#7#E )1)9)9)=)=>QSW)X&-5-=-=-A-A #T. )*&&**="= G"-"3"3C"8!DnU5%*\\^NF&,FO #9 *1Xt)DD  X &*1++eT*BD  Y ' rYautoc UURUU S.n SU0n URc]U(a [n SnO[n SnU "UUUUUU U S9n[SUS3U U S 9 UR XS 9nUR U5 SSS5 gU (a*[ RU 5n[RU5 U(a [n S nO[n S nU "UURUUU(aUOS UU S9n[SUS3U U S 9 UR(d"URXS 9 UR(dM"SSS5 g!,(df  g=f!,(df  g=f)aPerform a download without any error handling. This is intended to be called by :meth:`_prep_and_do_download` so it can be wrapped with error handling / remapping. :type transport: :class:`~google.auth.transport.requests.AuthorizedSession` :param transport: The transport (with credentials) that will make authenticated requests. :type file_obj: file :param file_obj: A file handle to which to write the blob's data. :type download_url: str :param download_url: The URL where the media can be accessed. :type headers: dict :param headers: Headers to be sent with the request(s). :type start: int :param start: (Optional) The first byte in a range to be downloaded. :type end: int :param end: (Optional) The last byte in a range to be downloaded. :type raw_download: bool :param raw_download: (Optional) If true, download the object without any expansion. :type timeout: float or tuple :param timeout: (Optional) The amount of time, in seconds, to wait for the server response. See: :ref:`configuring_timeouts` :type checksum: str :param checksum: (Optional) The type of checksum to compute to verify the integrity of the object. The response headers must contain a checksum of the requested type. If the headers lack an appropriate checksum (for instance in the case of transcoded or ranged downloads where the remote service does not know the correct checksum, including downloads where chunk_size is set) an INFO-level log will be emitted. Supported values are "md5", "crc32c", "auto" and None. The default is "auto", which will try to detect if the C extension for crc32c is installed and fall back to md5 otherwise. :type retry: google.api_core.retry.Retry :param retry: (Optional) How to retry the RPC. A None value will disable retries. A google.api_core.retry.Retry value will enable retries, and the object will configure backoff and timeout options. This private method does not accept ConditionalRetryPolicy values because the information necessary to evaluate the policy is instead evaluated in blob._prep_and_do_download(). See the retry.py source code and docstrings in this package (google.cloud.storage.retry) for information on retry types and how to configure them. )url.fullzdownload.chunk_sizezdownload.raw_downloadupload.checksumrNr r )streamrstartendchecksumrzStorage.z/consume)rA attributes api_requestrrr r)rr r rz/consumeNextChunk)rOr r r$consumer"_CHUNKED_DOWNLOAD_CHECKSUM_MESSAGEr_loggerinforr finishedconsume_next_chunk)rT transportfile_obj download_urlrr r  raw_downloadrr rextra_attributesargsklassdownload_classdownloadrmsgs rW _do_downloadBlob._do_downloadsV%&*oo%6%1"*   7# ?? "#!. !+!H#/x8+  $++I+G33H= 8??I S!*!5'!2$e!H#//@A+  #++// /K#+++ ;:s!D692E6 E Ec[SS9 URUUUUUUUUU U U U U US9 SSS5 g!,(df  g=f)aDownload the contents of this blob into a file-like object. .. note:: If the server-set property, :attr:`media_link`, is not yet initialized, makes an additional API request to load it. If the :attr:`chunk_size` of a current blob is `None`, will download data in single download request otherwise it will download the :attr:`chunk_size` of data in each request. For more fine-grained control over the download process, check out [`google-resumable-media`](https://googleapis.dev/python/google-resumable-media/latest/index.html). For example, this library allows downloading **parts** of a blob rather than the whole thing. If :attr:`user_project` is set on the bucket, bills the API request to that project. :type file_obj: file :param file_obj: A file handle to which to write the blob's data. :type client: :class:`~google.cloud.storage.client.Client` :param client: (Optional) The client to use. If not passed, falls back to the ``client`` stored on the blob's bucket. :type start: int :param start: (Optional) The first byte in a range to be downloaded. :type end: int :param end: (Optional) The last byte in a range to be downloaded. :type raw_download: bool :param raw_download: (Optional) If true, download the object without any expansion. :type if_etag_match: Union[str, Set[str]] :param if_etag_match: (Optional) See :ref:`using-if-etag-match` :type if_etag_not_match: Union[str, Set[str]] :param if_etag_not_match: (Optional) See :ref:`using-if-etag-not-match` :type if_generation_match: long :param if_generation_match: (Optional) See :ref:`using-if-generation-match` :type if_generation_not_match: long :param if_generation_not_match: (Optional) See :ref:`using-if-generation-not-match` :type if_metageneration_match: long :param if_metageneration_match: (Optional) See :ref:`using-if-metageneration-match` :type if_metageneration_not_match: long :param if_metageneration_not_match: (Optional) See :ref:`using-if-metageneration-not-match` :type timeout: float or tuple :param timeout: (Optional) The amount of time, in seconds, to wait for the server response. See: :ref:`configuring_timeouts` :type checksum: str :param checksum: (Optional) The type of checksum to compute to verify the integrity of the object. The response headers must contain a checksum of the requested type. If the headers lack an appropriate checksum (for instance in the case of transcoded or ranged downloads where the remote service does not know the correct checksum, including downloads where chunk_size is set) an INFO-level log will be emitted. Supported values are "md5", "crc32c", "auto" and None. The default is "auto", which will try to detect if the C extension for crc32c is installed and fall back to md5 otherwise. :type retry: google.api_core.retry.Retry or google.cloud.storage.retry.ConditionalRetryPolicy :param retry: (Optional) How to retry the RPC. A None value will disable retries. A google.api_core.retry.Retry value will enable retries, and the object will define retriable response codes and errors and configure backoff and timeout options. A google.cloud.storage.retry.ConditionalRetryPolicy value wraps a Retry object and activates it only if certain conditions are met. This class exists to provide safe defaults for RPC calls that are not technically safe to retry normally (due to potential data duplication or other side-effects) but become safe to retry if a condition such as if_metageneration_match is set. See the retry.py source code and docstrings in this package (google.cloud.storage.retry) for information on retry types and how to configure them. :raises: :class:`google.cloud.exceptions.NotFound` zStorage.Blob.downloadToFilerH r{r r rrrrrrrrr rN)r$_prep_and_do_download)rTrr{r r rrrrrrrrr rs rWdownload_to_fileBlob.download_to_fileZsXb$A B  & &)+"3$7(?(?,G! ' C B B0 >cX[US5nUR"U/UQ70UD6 SSS5 UR nUb3UR5n[R"WRXf45 gg!,(df  NQ=f![[4a [R "U5 ef=f)zDownload the contents of this blob into a named file. :type filename: str :param filename: A filename to be passed to ``open``. For *args and **kwargs, refer to the documentation for download_to_filename() for more information. wbN) openr$r.rosremoveupdated timestamputimerA)rTfilenamerkwargsrr-mtimes rW_handle_filename_and_download"Blob._handle_filename_and_downloads h%**&,,  %%'E HHX]]UN 3 &%)  IIh   s' BA0B0 A>:B>B(B)c[SS9 URUUUUUUUUU U U U U US9 SSS5 g!,(df  g=f)a Download the contents of this blob into a named file. If :attr:`user_project` is set on the bucket, bills the API request to that project. See a [code sample](https://cloud.google.com/storage/docs/samples/storage-download-encrypted-file#storage_download_encrypted_file-python) to download a file with a [`customer-supplied encryption key`](https://cloud.google.com/storage/docs/encryption#customer-supplied). :type filename: str :param filename: A filename to be passed to ``open``. :type client: :class:`~google.cloud.storage.client.Client` :param client: (Optional) The client to use. If not passed, falls back to the ``client`` stored on the blob's bucket. :type start: int :param start: (Optional) The first byte in a range to be downloaded. :type end: int :param end: (Optional) The last byte in a range to be downloaded. :type raw_download: bool :param raw_download: (Optional) If true, download the object without any expansion. :type if_etag_match: Union[str, Set[str]] :param if_etag_match: (Optional) See :ref:`using-if-etag-match` :type if_etag_not_match: Union[str, Set[str]] :param if_etag_not_match: (Optional) See :ref:`using-if-etag-not-match` :type if_generation_match: long :param if_generation_match: (Optional) See :ref:`using-if-generation-match` :type if_generation_not_match: long :param if_generation_not_match: (Optional) See :ref:`using-if-generation-not-match` :type if_metageneration_match: long :param if_metageneration_match: (Optional) See :ref:`using-if-metageneration-match` :type if_metageneration_not_match: long :param if_metageneration_not_match: (Optional) See :ref:`using-if-metageneration-not-match` :type timeout: float or tuple :param timeout: (Optional) The amount of time, in seconds, to wait for the server response. See: :ref:`configuring_timeouts` :type checksum: str :param checksum: (Optional) The type of checksum to compute to verify the integrity of the object. The response headers must contain a checksum of the requested type. If the headers lack an appropriate checksum (for instance in the case of transcoded or ranged downloads where the remote service does not know the correct checksum, including downloads where chunk_size is set) an INFO-level log will be emitted. Supported values are "md5", "crc32c", "auto" and None. The default is "auto", which will try to detect if the C extension for crc32c is installed and fall back to md5 otherwise. :type retry: google.api_core.retry.Retry or google.cloud.storage.retry.ConditionalRetryPolicy :param retry: (Optional) How to retry the RPC. A None value will disable retries. A google.api_core.retry.Retry value will enable retries, and the object will define retriable response codes and errors and configure backoff and timeout options. A google.cloud.storage.retry.ConditionalRetryPolicy value wraps a Retry object and activates it only if certain conditions are met. This class exists to provide safe defaults for RPC calls that are not technically safe to retry normally (due to potential data duplication or other side-effects) but become safe to retry if a condition such as if_metageneration_match is set. See the retry.py source code and docstrings in this package (google.cloud.storage.retry) for information on retry types and how to configure them. :raises: :class:`google.cloud.exceptions.NotFound` zStorage.Blob.downloadToFilenamerHr#N)r$r3)rTr0r{r r rrrrrrrrr rs rWdownload_to_filenameBlob.download_to_filenamesXN$E F  . .)+"3$7(?(?,G! / G F Fr'c[SS9 [5nURUUUUUUUUUU U U U U S9 UR5sSSS5 $!,(df  g=f)af Download the contents of this blob as a bytes object. If :attr:`user_project` is set on the bucket, bills the API request to that project. :type client: :class:`~google.cloud.storage.client.Client` :param client: (Optional) The client to use. If not passed, falls back to the ``client`` stored on the blob's bucket. :type start: int :param start: (Optional) The first byte in a range to be downloaded. :type end: int :param end: (Optional) The last byte in a range to be downloaded. :type raw_download: bool :param raw_download: (Optional) If true, download the object without any expansion. :type if_etag_match: Union[str, Set[str]] :param if_etag_match: (Optional) See :ref:`using-if-etag-match` :type if_etag_not_match: Union[str, Set[str]] :param if_etag_not_match: (Optional) See :ref:`using-if-etag-not-match` :type if_generation_match: long :param if_generation_match: (Optional) See :ref:`using-if-generation-match` :type if_generation_not_match: long :param if_generation_not_match: (Optional) See :ref:`using-if-generation-not-match` :type if_metageneration_match: long :param if_metageneration_match: (Optional) See :ref:`using-if-metageneration-match` :type if_metageneration_not_match: long :param if_metageneration_not_match: (Optional) See :ref:`using-if-metageneration-not-match` :type timeout: float or tuple :param timeout: (Optional) The amount of time, in seconds, to wait for the server response. See: :ref:`configuring_timeouts` :type checksum: str :param checksum: (Optional) The type of checksum to compute to verify the integrity of the object. The response headers must contain a checksum of the requested type. If the headers lack an appropriate checksum (for instance in the case of transcoded or ranged downloads where the remote service does not know the correct checksum, including downloads where chunk_size is set) an INFO-level log will be emitted. Supported values are "md5", "crc32c", "auto" and None. The default is "auto", which will try to detect if the C extension for crc32c is installed and fall back to md5 otherwise. :type retry: google.api_core.retry.Retry or google.cloud.storage.retry.ConditionalRetryPolicy :param retry: (Optional) How to retry the RPC. A None value will disable retries. A google.api_core.retry.Retry value will enable retries, and the object will define retriable response codes and errors and configure backoff and timeout options. A google.cloud.storage.retry.ConditionalRetryPolicy value wraps a Retry object and activates it only if certain conditions are met. This class exists to provide safe defaults for RPC calls that are not technically safe to retry normally (due to potential data duplication or other side-effects) but become safe to retry if a condition such as if_metageneration_match is set. See the retry.py source code and docstrings in this package (google.cloud.storage.retry) for information on retry types and how to configure them. :rtype: bytes :returns: The data stored in this blob. :raises: :class:`google.cloud.exceptions.NotFound` zStorage.Blob.downloadAsBytesrHr#N)r$rr$getvalue)rTr{r r rrrrrrrrr r string_buffers rWdownload_as_bytesBlob.download_as_bytesqsmF$B C#IM  & &)+"3$7(?(?,G! '  !))+'D C Cs 6A  Ac [R"[[SS9 [ SS9 UR UUUUUUUUU U U U S9 sSSS5 $!,(df  g=f)a* (Deprecated) Download the contents of this blob as a bytes object. If :attr:`user_project` is set on the bucket, bills the API request to that project. .. note:: Deprecated alias for :meth:`download_as_bytes`. :type client: :class:`~google.cloud.storage.client.Client` :param client: (Optional) The client to use. If not passed, falls back to the ``client`` stored on the blob's bucket. :type start: int :param start: (Optional) The first byte in a range to be downloaded. :type end: int :param end: (Optional) The last byte in a range to be downloaded. :type raw_download: bool :param raw_download: (Optional) If true, download the object without any expansion. :type if_etag_match: Union[str, Set[str]] :param if_etag_match: (Optional) See :ref:`using-if-etag-match` :type if_etag_not_match: Union[str, Set[str]] :param if_etag_not_match: (Optional) See :ref:`using-if-etag-not-match` :type if_generation_match: long :param if_generation_match: (Optional) See :ref:`using-if-generation-match` :type if_generation_not_match: long :param if_generation_not_match: (Optional) See :ref:`using-if-generation-not-match` :type if_metageneration_match: long :param if_metageneration_match: (Optional) See :ref:`using-if-metageneration-match` :type if_metageneration_not_match: long :param if_metageneration_not_match: (Optional) See :ref:`using-if-metageneration-not-match` :type timeout: float or tuple :param timeout: (Optional) The amount of time, in seconds, to wait for the server response. See: :ref:`configuring_timeouts` :type retry: google.api_core.retry.Retry or google.cloud.storage.retry.ConditionalRetryPolicy :param retry: (Optional) How to retry the RPC. A None value will disable retries. A google.api_core.retry.Retry value will enable retries, and the object will define retriable response codes and errors and configure backoff and timeout options. A google.cloud.storage.retry.ConditionalRetryPolicy value wraps a Retry object and activates it only if certain conditions are met. This class exists to provide safe defaults for RPC calls that are not technically safe to retry normally (due to potential data duplication or other side-effects) but become safe to retry if a condition such as if_metageneration_match is set. See the retry.py source code and docstrings in this package (google.cloud.storage.retry) for information on retry types and how to configure them. :rtype: bytes :returns: The data stored in this blob. :raises: :class:`google.cloud.exceptions.NotFound` rrzStorage.Blob.downloadAsStringrH r{r r rrrrrrrrrN)rr_DOWNLOAD_AS_STRING_DEPRECATEDrr$r;) rTr{r r rrrrrrrrrs rWdownload_as_stringBlob.download_as_stringsir  *,ERS $C D)))+"3$7(?(?,G* E D Ds A  Ac[SS9 URUUUUUUUU U U U U S9 nUbURU5sSSS5 $URbe[ 5R SUR-5n[ UR5SS5nSU;aURUS5sSSS5 $URS5sSSS5 $!,(df  g=f) a{ Download the contents of this blob as text (*not* bytes). If :attr:`user_project` is set on the bucket, bills the API request to that project. :type client: :class:`~google.cloud.storage.client.Client` :param client: (Optional) The client to use. If not passed, falls back to the ``client`` stored on the blob's bucket. :type start: int :param start: (Optional) The first byte in a range to be downloaded. :type end: int :param end: (Optional) The last byte in a range to be downloaded. :type raw_download: bool :param raw_download: (Optional) If true, download the object without any expansion. :type encoding: str :param encoding: (Optional) encoding to be used to decode the downloaded bytes. Defaults to the ``charset`` param of attr:`content_type`, or else to "utf-8". :type if_etag_match: Union[str, Set[str]] :param if_etag_match: (Optional) See :ref:`using-if-etag-match` :type if_etag_not_match: Union[str, Set[str]] :param if_etag_not_match: (Optional) See :ref:`using-if-etag-not-match` :type if_generation_match: long :param if_generation_match: (Optional) See :ref:`using-if-generation-match` :type if_generation_not_match: long :param if_generation_not_match: (Optional) See :ref:`using-if-generation-not-match` :type if_metageneration_match: long :param if_metageneration_match: (Optional) See :ref:`using-if-metageneration-match` :type if_metageneration_not_match: long :param if_metageneration_not_match: (Optional) See :ref:`using-if-metageneration-not-match` :type timeout: float or tuple :param timeout: (Optional) The amount of time, in seconds, to wait for the server response. See: :ref:`configuring_timeouts` :type retry: google.api_core.retry.Retry or google.cloud.storage.retry.ConditionalRetryPolicy :param retry: (Optional) How to retry the RPC. A None value will disable retries. A google.api_core.retry.Retry value will enable retries, and the object will define retriable response codes and errors and configure backoff and timeout options. A google.cloud.storage.retry.ConditionalRetryPolicy value wraps a Retry object and activates it only if certain conditions are met. This class exists to provide safe defaults for RPC calls that are not technically safe to retry normally (due to potential data duplication or other side-effects) but become safe to retry if a condition such as if_metageneration_match is set. See the retry.py source code and docstrings in this package (google.cloud.storage.retry) for information on retry types and how to configure them. :rtype: text :returns: The data stored in this blob, decoded to text. zStorage.Blob.downloadAsTextrHr>NzContent-Type: charsetutf-8)r$r;decoderrparsestrdict get_params)rTr{r r rencodingrrrrrrrrdatarrs rWdownload_as_textBlob.download_as_textUst$A B)))+"3$7(?(?,G* D#{{8,#C B&  ,"n--.>ARAR.RScnn.qr23&;;vi'89/C B2;;w'3C B Bs.CA(C4C CcrUc URnUcUb[R"U5upUc[nU$)aDetermine the content type from the current object. The return value will be determined in order of precedence: - The value passed in to this method (if not :data:`None`) - The value stored on the current blob - The default value ('application/octet-stream') :type content_type: str :param content_type: (Optional) Type of content. :type filename: str :param filename: (Optional) The name of the file where the content is stored. :rtype: str :returns: Type of content gathered from the object. )r mimetypes guess_type_DEFAULT_CONTENT_TYPE)rTrr0_s rW_get_content_typeBlob._get_content_typesC&  ,,L  H$8'228U$V W & 2  # #+-HI +85EF  (  #"* 7# 3'  4,'H   s H33 Ic URU5nUcURnUc[nURU5nSUR;a+SUR ;aUR R S5 URXUS9nUunnnUbURU5 [UR5n[RUURR[S9n/nUR bUR#SUR 45 UR$b-SUR$;aUR#SUR$45 UbUR#SU45 UbUR#SU45 U bUR#S U 45 U bUR#S U 45 U bUR#S U 45 ['UU5n[)UUUXS 9nUR+UUUUUS U S9 UU4$)a>Initiate a resumable upload. The content type of the upload will be determined in order of precedence: - The value passed in to this method (if not :data:`None`) - The value stored on the current blob - The default value ('application/octet-stream') :type client: :class:`~google.cloud.storage.client.Client` :param client: (Optional) The client to use. If not passed, falls back to the ``client`` stored on the blob's bucket. :type stream: IO[bytes] :param stream: A bytes IO object open for reading. :type content_type: str :param content_type: Type of content being uploaded (or :data:`None`). :type size: int :param size: The number of bytes to be uploaded (which will be read from ``stream``). If not provided, the upload will be concluded once ``stream`` is exhausted (or :data:`None`). :type predefined_acl: str :param predefined_acl: (Optional) Predefined access control list :type extra_headers: dict :param extra_headers: (Optional) Extra headers to add to standard headers. :type chunk_size: int :param chunk_size: (Optional) Chunk size to use when creating a :class:`~google.cloud.storage._media.requests.ResumableUpload`. If not passed, will fall back to the chunk size on the current blob, if the chunk size of a current blob is also `None`, will set the default value. The default value of ``chunk_size`` is 100 MB. :type if_generation_match: long :param if_generation_match: (Optional) See :ref:`using-if-generation-match` :type if_generation_not_match: long :param if_generation_not_match: (Optional) See :ref:`using-if-generation-not-match` :type if_metageneration_match: long :param if_metageneration_match: (Optional) See :ref:`using-if-metageneration-match` :type if_metageneration_not_match: long :param if_metageneration_not_match: (Optional) See :ref:`using-if-metageneration-not-match` :type timeout: float or tuple :param timeout: (Optional) The amount of time, in seconds, to wait for the server response. See: :ref:`configuring_timeouts` :type checksum: str :param checksum: (Optional) The type of checksum to compute to verify the integrity of the object. After the upload is complete, the server-computed checksum of the resulting object will be checked and google.cloud.storage.exceptions.DataCorruption will be raised on a mismatch. On a validation failure, the client will attempt to delete the uploaded object automatically. Supported values are "md5", "crc32c", "auto" and None. The default is "auto", which will try to detect if the C extension for crc32c is installed and fall back to md5 otherwise. :type retry: google.api_core.retry.Retry :param retry: (Optional) How to retry the RPC. A None value will disable retries. A google.api_core.retry.Retry value will enable retries, and the object will configure backoff and timeout options. This private method does not accept ConditionalRetryPolicy values because the information necessary to evaluate the policy is instead evaluated in blob._do_upload(). See the retry.py source code and docstrings in this package (google.cloud.storage.retry) for information on retry types and how to configure them. :type command: str :param command: (Optional) Information about which interface for upload was used, to be included in the X-Goog-API-Client header. Please leave as None unless otherwise directed. :rtype: tuple :returns: Pair of * The :class:`~google.cloud.storage._media.requests.ResumableUpload` that was created * The ``transport`` used to initiate the upload. r@r^rerrfrKrgrhrirjrkrlF) total_bytes stream_finalr)rrO_DEFAULT_CHUNKSIZErrSrVrqrbrrr_RESUMABLE_URL_TEMPLATErrUrxr"r~rrJrrinitiate)rTr{r rrtru extra_headersrOrrrrrr rr_rrrrXrrrrvrws rW_initiate_resumable_uploadBlob._initiate_resumable_uploadsp%%f-  J!/ ''/ )) )j .M MM  j )))&)P15.,  $ NN= )!&"4"45*114;;+;+;2     (  # #]D4E4E$F G    )#4+<+<<  # #\43D3D$E F  %  # #_n$E F  *  # #%8:M$N O " .  # #%;=T$U V " .  # #%<>U$V W & 2  # #+-HI +85EF   Gh        y  rYcrURUUUUUUUUU U U U U S9 upURURU S.nSU 0n[SUUUS9 UR(d#UR XS9nUR(dM#WsSSS5 $![ a UR5 ef=f!,(df  g=f)a Perform a resumable upload. Assumes ``chunk_size`` is not :data:`None` on the current blob. The default value of ``chunk_size`` is 100 MB. The content type of the upload will be determined in order of precedence: - The value passed in to this method (if not :data:`None`) - The value stored on the current blob - The default value ('application/octet-stream') :type client: :class:`~google.cloud.storage.client.Client` :param client: (Optional) The client to use. If not passed, falls back to the ``client`` stored on the blob's bucket. :type stream: IO[bytes] :param stream: A bytes IO object open for reading. :type content_type: str :param content_type: Type of content being uploaded (or :data:`None`). :type size: int :param size: The number of bytes to be uploaded (which will be read from ``stream``). If not provided, the upload will be concluded once ``stream`` is exhausted (or :data:`None`). :type predefined_acl: str :param predefined_acl: (Optional) Predefined access control list :type if_generation_match: long :param if_generation_match: (Optional) See :ref:`using-if-generation-match` :type if_generation_not_match: long :param if_generation_not_match: (Optional) See :ref:`using-if-generation-not-match` :type if_metageneration_match: long :param if_metageneration_match: (Optional) See :ref:`using-if-metageneration-match` :type if_metageneration_not_match: long :param if_metageneration_not_match: (Optional) See :ref:`using-if-metageneration-not-match` :type timeout: float or tuple :param timeout: (Optional) The amount of time, in seconds, to wait for the server response. See: :ref:`configuring_timeouts` :type checksum: str :param checksum: (Optional) The type of checksum to compute to verify the integrity of the object. After the upload is complete, the server-computed checksum of the resulting object will be checked and google.cloud.storage.exceptions.DataCorruption will be raised on a mismatch. On a validation failure, the client will attempt to delete the uploaded object automatically. Supported values are "md5", "crc32c", "auto" and None. The default is "auto", which will try to detect if the C extension for crc32c is installed and fall back to md5 otherwise. :type retry: google.api_core.retry.Retry :param retry: (Optional) How to retry the RPC. A None value will disable retries. A google.api_core.retry.Retry value will enable retries, and the object will configure backoff and timeout options. This private method does not accept ConditionalRetryPolicy values because the information necessary to evaluate the policy is instead evaluated in blob._do_upload(). See the retry.py source code and docstrings in this package (google.cloud.storage.retry) for information on retry types and how to configure them. :type command: str :param command: (Optional) Information about which interface for upload was used, to be included in the X-Goog-API-Client header. Please leave as None unless otherwise directed. :rtype: :class:`~requests.Response` :returns: The "200 OK" response object returned after the final chunk is uploaded. ) rurrrrrr rr_)rzupload.chunk_sizerrz)Storage.ResumableUpload/transmitNextChunkrmrN)r resumable_urlrOr$rtransmit_next_chunkr.r)rTr{r rrtrurrrrrr rr_rwrrrrs rW_do_resumable_uploadBlob._do_resumable_uploadsP!;;    ) 3$;$;(C<  ,,!'!2!2"*  7# <'  oo%99)9UHooo  &KKM  s* B(B +B(>B( B%%B(( B6c[U [5(aUUS.nU RUS9n Ub5U[::a+UR UUUUUUUUU U U U U S9 nUR 5$UR UUUUUUUUU U U U U S9 nUR 5$)aGDetermine an upload strategy and then perform the upload. If the size of the data to be uploaded exceeds 8 MB a resumable media request will be used, otherwise the content and the metadata will be uploaded in a single multipart upload request. The content type of the upload will be determined in order of precedence: - The value passed in to this method (if not :data:`None`) - The value stored on the current blob - The default value ('application/octet-stream') :type client: :class:`~google.cloud.storage.client.Client` :param client: (Optional) The client to use. If not passed, falls back to the ``client`` stored on the blob's bucket. :type stream: IO[bytes] :param stream: A bytes IO object open for reading. :type content_type: str :param content_type: Type of content being uploaded (or :data:`None`). :type size: int :param size: The number of bytes to be uploaded (which will be read from ``stream``). If not provided, the upload will be concluded once ``stream`` is exhausted (or :data:`None`). :type predefined_acl: str :param predefined_acl: (Optional) Predefined access control list :type if_generation_match: long :param if_generation_match: (Optional) See :ref:`using-if-generation-match` :type if_generation_not_match: long :param if_generation_not_match: (Optional) See :ref:`using-if-generation-not-match` :type if_metageneration_match: long :param if_metageneration_match: (Optional) See :ref:`using-if-metageneration-match` :type if_metageneration_not_match: long :param if_metageneration_not_match: (Optional) See :ref:`using-if-metageneration-not-match` :type timeout: float or tuple :param timeout: (Optional) The amount of time, in seconds, to wait for the server response. See: :ref:`configuring_timeouts` :type checksum: str :param checksum: (Optional) The type of checksum to compute to verify the integrity of the object. If the upload is completed in a single request, the checksum will be entirely precomputed and the remote server will handle verification and error handling. If the upload is too large and must be transmitted in multiple requests, the checksum will be incrementally computed and the client will handle verification and error handling, raising google.cloud.storage.exceptions.DataCorruption on a mismatch and attempting to delete the corrupted file. Supported values are "md5", "crc32c", "auto" and None. The default is "auto", which will try to detect if the C extension for crc32c is installed and fall back to md5 otherwise. :type retry: google.api_core.retry.Retry or google.cloud.storage.retry.ConditionalRetryPolicy :param retry: (Optional) How to retry the RPC. A None value will disable retries. A google.api_core.retry.Retry value will enable retries, and the object will define retriable response codes and errors and configure backoff and timeout options. A google.cloud.storage.retry.ConditionalRetryPolicy value wraps a Retry object and activates it only if certain conditions are met. This class exists to provide safe defaults for RPC calls that are not technically safe to retry normally (due to potential data duplication or other side-effects) but become safe to retry if a condition such as if_generation_match is set. See the retry.py source code and docstrings in this package (google.cloud.storage.retry) for information on retry types and how to configure them. :type command: str :param command: (Optional) Information about which interface for upload was used, to be included in the X-Goog-API-Client header. Please leave as None unless otherwise directed. :rtype: dict :returns: The parsed JSON from the "200 OK" response. This will be the **only** response in the multipart case and it will be the **final** response in the resumable case. rhrjrrr rr_) isinstancer0"get_retry_policy_if_conditions_met_MAX_MULTIPART_SIZErxrjson)rTr{r rrtrurrrrrr rr_rrs rW _do_uploadBlob._do_upload$ sf e3 4 4 &9)@L<<,<WE  (; ;00#''+!1H@}}!00#''+!1H }}rYc[XS9 [R"U5nURUUUUUUUU U U U U US9 nUR U5 g![ an[ U5 SnAgSnAff=f)aUpload the contents of this blob from a file-like object. The content type of the upload will be determined in order of precedence: - The value passed in to this method (if not :data:`None`) - The value stored on the current blob - The default value ('application/octet-stream') .. note:: The effect of uploading to an existing blob depends on the "versioning" and "lifecycle" policies defined on the blob's bucket. In the absence of those policies, upload will overwrite any existing contents. See the [`object versioning`](https://cloud.google.com/storage/docs/object-versioning) and [`lifecycle`](https://cloud.google.com/storage/docs/lifecycle) API documents for details. If the size of the data to be uploaded exceeds 8 MB a resumable media request will be used, otherwise the content and the metadata will be uploaded in a single multipart upload request. For more fine-grained over the upload process, check out [`google-resumable-media`](https://googleapis.dev/python/google-resumable-media/latest/index.html). If :attr:`user_project` is set on the bucket, bills the API request to that project. :type file_obj: file :param file_obj: A file handle opened in binary mode for reading. :type rewind: bool :param rewind: If True, seek to the beginning of the file handle before writing the file to Cloud Storage. :type size: int :param size: The number of bytes to be uploaded (which will be read from ``file_obj``). If not provided, the upload will be concluded once ``file_obj`` is exhausted. :type content_type: str :param content_type: (Optional) Type of content being uploaded. :type client: :class:`~google.cloud.storage.client.Client` :param client: (Optional) The client to use. If not passed, falls back to the ``client`` stored on the blob's bucket. :type predefined_acl: str :param predefined_acl: (Optional) Predefined access control list :type if_generation_match: long :param if_generation_match: (Optional) See :ref:`using-if-generation-match` :type if_generation_not_match: long :param if_generation_not_match: (Optional) See :ref:`using-if-generation-not-match` :type if_metageneration_match: long :param if_metageneration_match: (Optional) See :ref:`using-if-metageneration-match` :type if_metageneration_not_match: long :param if_metageneration_not_match: (Optional) See :ref:`using-if-metageneration-not-match` :type timeout: float or tuple :param timeout: (Optional) The amount of time, in seconds, to wait for the server response. See: :ref:`configuring_timeouts` :type checksum: str :param checksum: (Optional) The type of checksum to compute to verify the integrity of the object. If the upload is completed in a single request, the checksum will be entirely precomputed and the remote server will handle verification and error handling. If the upload is too large and must be transmitted in multiple requests, the checksum will be incrementally computed and the client will handle verification and error handling, raising google.cloud.storage.exceptions.DataCorruption on a mismatch and attempting to delete the corrupted file. Supported values are "md5", "crc32c", "auto" and None. The default is "auto", which will try to detect if the C extension for crc32c is installed and fall back to md5 otherwise. :type retry: google.api_core.retry.Retry or google.cloud.storage.retry.ConditionalRetryPolicy :param retry: (Optional) How to retry the RPC. A None value will disable retries. A google.api_core.retry.Retry value will enable retries, and the object will define retriable response codes and errors and configure backoff and timeout options. A google.cloud.storage.retry.ConditionalRetryPolicy value wraps a Retry object and activates it only if certain conditions are met. This class exists to provide safe defaults for RPC calls that are not technically safe to retry normally (due to potential data duplication or other side-effects) but become safe to retry if a condition such as if_generation_match is set. See the retry.py source code and docstrings in this package (google.cloud.storage.retry) for information on retry types and how to configure them. :type command: str :param command: (Optional) Information about which interface for upload was used, to be included in the X-Goog-API-Client header. Please leave as None unless otherwise directed. :raises: :class:`~google.cloud.exceptions.GoogleCloudError` if the upload response returns an error status. )rewindrN) _maybe_rewindr%validate_predefinedr_set_propertiesr/_raise_from_invalid_response)rTrrrtrr{rurrrrrr rr_ created_jsonexcs rW_prep_and_do_uploadBlob._prep_and_do_upload sJ h.00@ .??#''+!+L   . . ( - - .s,A A- A((A-c[SS9 URUUUUUUUUU U U U U S9 SSS5 g!,(df  g=f)a4Upload the contents of this blob from a file-like object. The content type of the upload will be determined in order of precedence: - The value passed in to this method (if not :data:`None`) - The value stored on the current blob - The default value ('application/octet-stream') .. note:: The effect of uploading to an existing blob depends on the "versioning" and "lifecycle" policies defined on the blob's bucket. In the absence of those policies, upload will overwrite any existing contents. See the [`object versioning`](https://cloud.google.com/storage/docs/object-versioning) and [`lifecycle`](https://cloud.google.com/storage/docs/lifecycle) API documents for details. If the size of the data to be uploaded exceeds 8 MB a resumable media request will be used, otherwise the content and the metadata will be uploaded in a single multipart upload request. For more fine-grained over the upload process, check out [`google-resumable-media`](https://googleapis.dev/python/google-resumable-media/latest/index.html). If :attr:`user_project` is set on the bucket, bills the API request to that project. :type file_obj: file :param file_obj: A file handle opened in binary mode for reading. :type rewind: bool :param rewind: If True, seek to the beginning of the file handle before writing the file to Cloud Storage. :type size: int :param size: The number of bytes to be uploaded (which will be read from ``file_obj``). If not provided, the upload will be concluded once ``file_obj`` is exhausted. :type content_type: str :param content_type: (Optional) Type of content being uploaded. :type client: :class:`~google.cloud.storage.client.Client` :param client: (Optional) The client to use. If not passed, falls back to the ``client`` stored on the blob's bucket. :type predefined_acl: str :param predefined_acl: (Optional) Predefined access control list :type if_generation_match: long :param if_generation_match: (Optional) See :ref:`using-if-generation-match` :type if_generation_not_match: long :param if_generation_not_match: (Optional) See :ref:`using-if-generation-not-match` :type if_metageneration_match: long :param if_metageneration_match: (Optional) See :ref:`using-if-metageneration-match` :type if_metageneration_not_match: long :param if_metageneration_not_match: (Optional) See :ref:`using-if-metageneration-not-match` :type timeout: float or tuple :param timeout: (Optional) The amount of time, in seconds, to wait for the server response. See: :ref:`configuring_timeouts` :type checksum: str :param checksum: (Optional) The type of checksum to compute to verify the integrity of the object. If the upload is completed in a single request, the checksum will be entirely precomputed and the remote server will handle verification and error handling. If the upload is too large and must be transmitted in multiple requests, the checksum will be incrementally computed and the client will handle verification and error handling, raising google.cloud.storage.exceptions.DataCorruption on a mismatch and attempting to delete the corrupted file. Supported values are "md5", "crc32c", "auto" and None. The default is "auto", which will try to detect if the C extension for crc32c is installed and fall back to md5 otherwise. :type retry: google.api_core.retry.Retry or google.cloud.storage.retry.ConditionalRetryPolicy :param retry: (Optional) How to retry the RPC. A None value will disable retries. A google.api_core.retry.Retry value will enable retries, and the object will define retriable response codes and errors and configure backoff and timeout options. A google.cloud.storage.retry.ConditionalRetryPolicy value wraps a Retry object and activates it only if certain conditions are met. This class exists to provide safe defaults for RPC calls that are not technically safe to retry normally (due to potential data duplication or other side-effects) but become safe to retry if a condition such as if_generation_match is set. See the retry.py source code and docstrings in this package (google.cloud.storage.retry) for information on retry types and how to configure them. :raises: :class:`~google.cloud.exceptions.GoogleCloudError` if the upload response returns an error status. zStorage.Blob.uploadFromFilerH) rrtrr{rurrrrrr rN)r$r)rTrrrtrr{rurrrrrr rs rWupload_from_fileBlob.upload_from_filea sU|$A B  $ $)-$7(?(?,G! % C B Bs/ =cURX!S9n[US5n[R"UR 55R nUR "U/UQ7UUS.UD6 SSS5 g!,(df  g=f)a8Upload this blob's contents from the content of a named file. :type filename: str :param filename: The path to the file. :type content_type: str :param content_type: (Optional) Type of content being uploaded. For *args and **kwargs, refer to the documentation for upload_from_filename() for more information. r]rb)rrtN)rSr*r+fstatfilenost_sizer)rTr0rrr1rr{s rW_handle_filename_and_upload Blob._handle_filename_and_upload sz--l-N (D !X((8??#45==K  $ $   )     " ! !s AA-- A;c |[SS9 URUUUUUUUUU U U S9 SSS5 g!,(df  g=f)a:Upload this blob's contents from the content of a named file. The content type of the upload will be determined in order of precedence: - The value passed in to this method (if not :data:`None`) - The value stored on the current blob - The value given by ``mimetypes.guess_type`` - The default value ('application/octet-stream') .. note:: The effect of uploading to an existing blob depends on the "versioning" and "lifecycle" policies defined on the blob's bucket. In the absence of those policies, upload will overwrite any existing contents. See the [`object versioning`](https://cloud.google.com/storage/docs/object-versioning) and [`lifecycle`](https://cloud.google.com/storage/docs/lifecycle) API documents for details. If :attr:`user_project` is set on the bucket, bills the API request to that project. See a [code sample](https://cloud.google.com/storage/docs/samples/storage-upload-encrypted-file#storage_upload_encrypted_file-python) to upload a file with a [`customer-supplied encryption key`](https://cloud.google.com/storage/docs/encryption#customer-supplied). :type filename: str :param filename: The path to the file. :type content_type: str :param content_type: (Optional) Type of content being uploaded. :type client: :class:`~google.cloud.storage.client.Client` :param client: (Optional) The client to use. If not passed, falls back to the ``client`` stored on the blob's bucket. :type predefined_acl: str :param predefined_acl: (Optional) Predefined access control list :type if_generation_match: long :param if_generation_match: (Optional) See :ref:`using-if-generation-match` :type if_generation_not_match: long :param if_generation_not_match: (Optional) See :ref:`using-if-generation-not-match` :type if_metageneration_match: long :param if_metageneration_match: (Optional) See :ref:`using-if-metageneration-match` :type if_metageneration_not_match: long :param if_metageneration_not_match: (Optional) See :ref:`using-if-metageneration-not-match` :type timeout: float or tuple :param timeout: (Optional) The amount of time, in seconds, to wait for the server response. See: :ref:`configuring_timeouts` :type checksum: str :param checksum: (Optional) The type of checksum to compute to verify the integrity of the object. If the upload is completed in a single request, the checksum will be entirely precomputed and the remote server will handle verification and error handling. If the upload is too large and must be transmitted in multiple requests, the checksum will be incrementally computed and the client will handle verification and error handling, raising google.cloud.storage.exceptions.DataCorruption on a mismatch and attempting to delete the corrupted file. Supported values are "md5", "crc32c", "auto" and None. The default is "auto", which will try to detect if the C extension for crc32c is installed and fall back to md5 otherwise. :type retry: google.api_core.retry.Retry or google.cloud.storage.retry.ConditionalRetryPolicy :param retry: (Optional) How to retry the RPC. A None value will disable retries. A google.api_core.retry.Retry value will enable retries, and the object will define retriable response codes and errors and configure backoff and timeout options. A google.cloud.storage.retry.ConditionalRetryPolicy value wraps a Retry object and activates it only if certain conditions are met. This class exists to provide safe defaults for RPC calls that are not technically safe to retry normally (due to potential data duplication or other side-effects) but become safe to retry if a condition such as if_generation_match is set. See the retry.py source code and docstrings in this package (google.cloud.storage.retry) for information on retry types and how to configure them. zStorage.Blob.uploadFromFilenamerH) rr{rurrrrrr rN)r$r) rTr0rr{rurrrrrr rs rWupload_from_filenameBlob.upload_from_filename sOX$E F  , ,)-$7(?(?,G! - G F Fs- ;z text/plainc [SS9 [USS9n[U5n URU [ U5UUUUUUUU U U S9 SSS5 g!,(df  g=f)a Upload contents of this blob from the provided string. .. note:: The effect of uploading to an existing blob depends on the "versioning" and "lifecycle" policies defined on the blob's bucket. In the absence of those policies, upload will overwrite any existing contents. See the [`object versioning`](https://cloud.google.com/storage/docs/object-versioning) and [`lifecycle`](https://cloud.google.com/storage/docs/lifecycle) API documents for details. If :attr:`user_project` is set on the bucket, bills the API request to that project. :type data: bytes or str :param data: The data to store in this blob. If the value is text, it will be encoded as UTF-8. :type content_type: str :param content_type: (Optional) Type of content being uploaded. Defaults to ``'text/plain'``. :type client: :class:`~google.cloud.storage.client.Client` :param client: (Optional) The client to use. If not passed, falls back to the ``client`` stored on the blob's bucket. :type predefined_acl: str :param predefined_acl: (Optional) Predefined access control list :type if_generation_match: long :param if_generation_match: (Optional) See :ref:`using-if-generation-match` :type if_generation_not_match: long :param if_generation_not_match: (Optional) See :ref:`using-if-generation-not-match` :type if_metageneration_match: long :param if_metageneration_match: (Optional) See :ref:`using-if-metageneration-match` :type if_metageneration_not_match: long :param if_metageneration_not_match: (Optional) See :ref:`using-if-metageneration-not-match` :type timeout: float or tuple :param timeout: (Optional) The amount of time, in seconds, to wait for the server response. See: :ref:`configuring_timeouts` :type checksum: str :param checksum: (Optional) The type of checksum to compute to verify the integrity of the object. If the upload is completed in a single request, the checksum will be entirely precomputed and the remote server will handle verification and error handling. If the upload is too large and must be transmitted in multiple requests, the checksum will be incrementally computed and the client will handle verification and error handling, raising google.cloud.storage.exceptions.DataCorruption on a mismatch and attempting to delete the corrupted file. Supported values are "md5", "crc32c", "auto" and None. The default is "auto", which will try to detect if the C extension for crc32c is installed and fall back to md5 otherwise. :type retry: google.api_core.retry.Retry or google.cloud.storage.retry.ConditionalRetryPolicy :param retry: (Optional) How to retry the RPC. A None value will disable retries. A google.api_core.retry.Retry value will enable retries, and the object will define retriable response codes and errors and configure backoff and timeout options. A google.cloud.storage.retry.ConditionalRetryPolicy value wraps a Retry object and activates it only if certain conditions are met. This class exists to provide safe defaults for RPC calls that are not technically safe to retry normally (due to potential data duplication or other side-effects) but become safe to retry if a condition such as if_generation_match is set. See the retry.py source code and docstrings in this package (google.cloud.storage.retry) for information on retry types and how to configure them. zStorage.Blob.uploadFromStringrHrErJ) rrtrr{rurrrrrr rN)r$rrrro) rTrKrr{rurrrrrr rr:s rWupload_from_stringBlob.upload_from_string skH$C DTG4D#DMM  ! !&Y)-$7(?(?,G! " E D Ds 9A  Ac [SS9 [U [5(aUU S.n U RU S9n 0nUbX>S'[ S5nUR UUUUUUU U U UUR UUU S9unnURsSSS5 $![an[U5 SnAOSnAff=fSSS5 g!,(df  g=f) aCreate a resumable upload session. Resumable upload sessions allow you to start an upload session from one client and complete the session in another. This method is called by the initiator to set the metadata and limits. The initiator then passes the session URL to the client that will upload the binary data. The client performs a PUT request on the session URL to complete the upload. This process allows untrusted clients to upload to an access-controlled bucket. For more details, see the documentation on [`signed URLs`](https://cloud.google.com/storage/docs/access-control/signed-urls#signing-resumable). The content type of the upload will be determined in order of precedence: - The value passed in to this method (if not :data:`None`) - The value stored on the current blob - The default value ('application/octet-stream') .. note:: The effect of uploading to an existing blob depends on the "versioning" and "lifecycle" policies defined on the blob's bucket. In the absence of those policies, upload will overwrite any existing contents. See the [`object versioning`](https://cloud.google.com/storage/docs/object-versioning) and [`lifecycle`](https://cloud.google.com/storage/docs/lifecycle) API documents for details. If :attr:`encryption_key` is set, the blob will be encrypted with a [`customer-supplied`](https://cloud.google.com/storage/docs/encryption#customer-supplied) encryption key. If :attr:`user_project` is set on the bucket, bills the API request to that project. :type size: int :param size: (Optional) The maximum number of bytes that can be uploaded using this session. If the size is not known when creating the session, this should be left blank. :type content_type: str :param content_type: (Optional) Type of content being uploaded. :type origin: str :param origin: (Optional) If set, the upload can only be completed by a user-agent that uploads from the given origin. This can be useful when passing the session to a web client. :type client: :class:`~google.cloud.storage.client.Client` :param client: (Optional) The client to use. If not passed, falls back to the ``client`` stored on the blob's bucket. :type timeout: float or tuple :param timeout: (Optional) The amount of time, in seconds, to wait for the server response. See: :ref:`configuring_timeouts` :type checksum: str :param checksum: (Optional) The type of checksum to compute to verify the integrity of the object. After the upload is complete, the server-computed checksum of the resulting object will be checked and google.cloud.storage.exceptions.DataCorruption will be raised on a mismatch. On a validation failure, the client will attempt to delete the uploaded object automatically. Supported values are "md5", "crc32c", "auto" and None. The default is "auto", which will try to detect if the C extension for crc32c is installed and fall back to md5 otherwise. :type predefined_acl: str :param predefined_acl: (Optional) Predefined access control list :type if_generation_match: long :param if_generation_match: (Optional) See :ref:`using-if-generation-match` :type if_generation_not_match: long :param if_generation_not_match: (Optional) See :ref:`using-if-generation-not-match` :type if_metageneration_match: long :param if_metageneration_match: (Optional) See :ref:`using-if-metageneration-match` :type if_metageneration_not_match: long :param if_metageneration_not_match: (Optional) See :ref:`using-if-metageneration-not-match` :type retry: google.api_core.retry.Retry or google.cloud.storage.retry.ConditionalRetryPolicy :param retry: (Optional) How to retry the RPC. A None value will disable retries. A google.api_core.retry.Retry value will enable retries, and the object will define retriable response codes and errors and configure backoff and timeout options. A google.cloud.storage.retry.ConditionalRetryPolicy value wraps a Retry object and activates it only if certain conditions are met. This class exists to provide safe defaults for RPC calls that are not technically safe to retry normally (due to potential data duplication or other side-effects) but become safe to retry if a condition such as if_generation_match is set. See the retry.py source code and docstrings in this package (google.cloud.storage.retry) for information on retry types and how to configure them. :rtype: str :returns: The resumable upload session URL. The upload can be completed by making an HTTP PUT request with the file's contents. :raises: :class:`google.cloud.exceptions.GoogleCloudError` if the session creation response returns an error status. z)Storage.Blob.createResumableUploadSessionrHrrNOriginrY) rurrrrrrOrr r) r$rr0rrrrarr/r)rTrrtoriginr{rr rurrrrrrr fake_streamrwrRrs rWcreate_resumable_upload_session$Blob.create_resumable_upload_session sJ$O P%!788 *=-D  @@!-AM!+1h' 2%cl !;; #1(;,C,C0K"/#88#%< "++WQ PX# 2,S11 21[Q P Ps.3B3?B B& B!B3!B&&B33 Cc "[SS9 URU5n0nURbURUS'UbX%S'URURS3UUUSS9n[ R "U5sSSS5 $!,(df  g=f)aRetrieve the IAM policy for the object. .. note:: Blob- / object-level IAM support does not yet exist and methods currently call an internal ACL backend not providing any utility beyond the blob's :attr:`acl` at this time. The API may be enhanced in the future and is currently undocumented. Use :attr:`acl` for managing object access control. If :attr:`user_project` is set on the bucket, bills the API request to that project. :type client: :class:`~google.cloud.storage.client.Client` :param client: (Optional) The client to use. If not passed, falls back to the ``client`` stored on the current object's bucket. :type requested_policy_version: int or ``NoneType`` :param requested_policy_version: (Optional) The version of IAM policies to request. If a policy with a condition is requested without setting this, the server will return an error. This must be set to a value of 3 to retrieve IAM policies containing conditions. This is to prevent client code that isn't aware of IAM conditions from interpreting and modifying policies incorrectly. The service might return a policy with version lower than the one that was requested, based on the feature syntax in the policy fetched. :type timeout: float or tuple :param timeout: (Optional) The amount of time, in seconds, to wait for the server response. See: :ref:`configuring_timeouts` :type retry: google.api_core.retry.Retry or google.cloud.storage.retry.ConditionalRetryPolicy :param retry: (Optional) How to retry the RPC. See: :ref:`configuring_retries` :rtype: :class:`google.api_core.iam.Policy` :returns: the policy instance, based on the resource returned from the ``getIamPolicy`` API request. zStorage.Blob.getIamPolicyrHNroptionsRequestedPolicyVersion/iamrrrr)r$rr~rrxr from_api_repr)rTr{requested_policy_versionrrrrs rWget_iam_policyBlob.get_iam_policy sb$? @))&1FL  ,.2.?.? ]+'3@X<=''99+T")# (D''-%A @ @s A,B Bc X[SS9 URU5n0nURbURUS'URS3nUR 5nURUS'UR UUUUUSS9n[ R"U5sSSS5 $!,(df  g=f)aUpdate the IAM policy for the bucket. .. note:: Blob- / object-level IAM support does not yet exist and methods currently call an internal ACL backend not providing any utility beyond the blob's :attr:`acl` at this time. The API may be enhanced in the future and is currently undocumented. Use :attr:`acl` for managing object access control. If :attr:`user_project` is set on the bucket, bills the API request to that project. :type policy: :class:`google.api_core.iam.Policy` :param policy: policy instance used to update bucket's IAM policy. :type client: :class:`~google.cloud.storage.client.Client` :param client: (Optional) The client to use. If not passed, falls back to the ``client`` stored on the current bucket. :type timeout: float or tuple :param timeout: (Optional) The amount of time, in seconds, to wait for the server response. See: :ref:`configuring_timeouts` :type retry: google.api_core.retry.Retry or google.cloud.storage.retry.ConditionalRetryPolicy :param retry: (Optional) How to retry the RPC. See: :ref:`configuring_retries` :rtype: :class:`google.api_core.iam.Policy` :returns: the policy instance, based on the resource returned from the ``setIamPolicy`` API request. zStorage.Blob.setIamPolicyrHNrr resourceIdr)r$rr~rx to_api_repr _put_resourcerr) rTpolicyr{rrrrxrrs rWset_iam_policyBlob.set_iam_policy sR$? @))&1FL  ,.2.?.? ]+ii[%D))+H%)YYH\ "'')# (D''-'A @ @s BB B)c [SS9 URU5nSU0nURbURUS'URS3nUR UUUUSS9nUR S/5sSSS5 $!,(df  g=f)aAPI call: test permissions .. note:: Blob- / object-level IAM support does not yet exist and methods currently call an internal ACL backend not providing any utility beyond the blob's :attr:`acl` at this time. The API may be enhanced in the future and is currently undocumented. Use :attr:`acl` for managing object access control. If :attr:`user_project` is set on the bucket, bills the API request to that project. :type permissions: list of string :param permissions: the permissions to check :type client: :class:`~google.cloud.storage.client.Client` :param client: (Optional) The client to use. If not passed, falls back to the ``client`` stored on the current bucket. :type timeout: float or tuple :param timeout: (Optional) The amount of time, in seconds, to wait for the server response. See: :ref:`configuring_timeouts` :type retry: google.api_core.retry.Retry or google.cloud.storage.retry.ConditionalRetryPolicy :param retry: (Optional) How to retry the RPC. See: :ref:`configuring_retries` :rtype: list of string :returns: the permissions returned by the ``testIamPermissions`` API request. zStorage.Blob.testIamPermissionsrH permissionsNrz/iam/testPermissionsr)r$rr~rxrr)rTrr{rrrrxresps rWtest_iam_permissionsBlob.test_iam_permissions0 sJ$E F))&1F);7L  ,.2.?.? ]+ii[ 45D'')# (D88M2.!G F Fs A%A99 Bc [SS9 URR5R5 URR UUUUUUUS9 SSS5 g!,(df  g=f)agUpdate blob's ACL, granting read access to anonymous users. :type client: :class:`~google.cloud.storage.client.Client` or ``NoneType`` :param client: (Optional) The client to use. If not passed, falls back to the ``client`` stored on the blob's bucket. :type timeout: float or tuple :param timeout: (Optional) The amount of time, in seconds, to wait for the server response. See: :ref:`configuring_timeouts` :type if_generation_match: long :param if_generation_match: (Optional) See :ref:`using-if-generation-match` :type if_generation_not_match: long :param if_generation_not_match: (Optional) See :ref:`using-if-generation-not-match` :type if_metageneration_match: long :param if_metageneration_match: (Optional) See :ref:`using-if-metageneration-match` :type if_metageneration_not_match: long :param if_metageneration_not_match: (Optional) See :ref:`using-if-metageneration-not-match` :type retry: google.api_core.retry.Retry or google.cloud.storage.retry.ConditionalRetryPolicy :param retry: (Optional) How to retry the RPC. See: :ref:`configuring_retries` zStorage.Blob.makePublicrHr{rrrrrrN)r$rpall grant_readsaverTr{rrrrrrs rW make_publicBlob.make_publicg sZT$= > HHLLN % % ' HHMM$7(?(?,G  ? > > AA A)c [SS9 URR5R5 URR UUUUUUUS9 SSS5 g!,(df  g=f)ahUpdate blob's ACL, revoking read access for anonymous users. :type client: :class:`~google.cloud.storage.client.Client` or ``NoneType`` :param client: (Optional) The client to use. If not passed, falls back to the ``client`` stored on the blob's bucket. :type timeout: float or tuple :param timeout: (Optional) The amount of time, in seconds, to wait for the server response. See: :ref:`configuring_timeouts` :type if_generation_match: long :param if_generation_match: (Optional) See :ref:`using-if-generation-match` :type if_generation_not_match: long :param if_generation_not_match: (Optional) See :ref:`using-if-generation-not-match` :type if_metageneration_match: long :param if_metageneration_match: (Optional) See :ref:`using-if-metageneration-match` :type if_metageneration_not_match: long :param if_metageneration_not_match: (Optional) See :ref:`using-if-metageneration-not-match` :type retry: google.api_core.retry.Retry or google.cloud.storage.retry.ConditionalRetryPolicy :param retry: (Optional) How to retry the RPC. See: :ref:`configuring_retries` zStorage.Blob.makePrivaterHrN)r$rpr revoke_readrrs rW make_privateBlob.make_private s[T$> ? HHLLN & & ( HHMM$7(?(?,G  @ ? ?rc d[SS9 [U5nURU5n0n [U[5(a4[ R "[[SS9 Ub[[5eUnSn[U[5(a [ R "[[SS9 SnUcS/U-n[U5U:wa[[5e/n [X5HCupU RU RS.n 0nU bXS'U(aXS'U R!U 5 ME U UR"R%5S .nUR&bUR&U S '[)U UUS 9 UR+UR,S 3UU UUUS 9nUR/U5 SSS5 g!,(df  g=f)a Concatenate source blobs into this one. If :attr:`user_project` is set on the bucket, bills the API request to that project. See [API reference docs](https://cloud.google.com/storage/docs/json_api/v1/objects/compose) and a [code sample](https://cloud.google.com/storage/docs/samples/storage-compose-file#storage_compose_file-python). :type sources: list of :class:`Blob` :param sources: Blobs whose contents will be composed into this blob. :type client: :class:`~google.cloud.storage.client.Client` :param client: (Optional) The client to use. If not passed, falls back to the ``client`` stored on the blob's bucket. :type timeout: float or tuple :param timeout: (Optional) The amount of time, in seconds, to wait for the server response. See: :ref:`configuring_timeouts` :type if_generation_match: long :param if_generation_match: (Optional) Makes the operation conditional on whether the destination object's current generation matches the given value. Setting to 0 makes the operation succeed only if there are no live versions of the object. Note: In a previous version, this argument worked identically to the ``if_source_generation_match`` argument. For backwards-compatibility reasons, if a list is passed in, this argument will behave like ``if_source_generation_match`` and also issue a DeprecationWarning. :type if_metageneration_match: long :param if_metageneration_match: (Optional) Makes the operation conditional on whether the destination object's current metageneration matches the given value. If a list of long is passed in, no match operation will be performed. (Deprecated: type(list of long) is supported for backwards-compatability reasons only.) :type if_source_generation_match: list of long :param if_source_generation_match: (Optional) Makes the operation conditional on whether the current generation of each source blob matches the corresponding generation. The list must match ``sources`` item-to-item. :type retry: google.api_core.retry.Retry or google.cloud.storage.retry.ConditionalRetryPolicy :param retry: (Optional) How to retry the RPC. The default value is ``DEFAULT_RETRY_IF_GENERATION_SPECIFIED``, a conditional retry policy which will only enable retries if ``if_generation_match`` or ``generation`` is set, in order to ensure requests are idempotent before retrying them. Change the value to ``DEFAULT_RETRY`` or another `google.api_core.retry.Retry` object to enable retries regardless of generation precondition setting. See [Configuring Retries](https://cloud.google.com/python/docs/reference/storage/latest/retry_timeout). zStorage.Blob.composerHrrN)rArLrhobjectPreconditions) sourceObjects destinationr)rrz/composer)r$rorrlistrr&_COMPOSE_IF_GENERATION_LIST_DEPRECATEDDeprecationWarningrb:_COMPOSE_IF_GENERATION_LIST_AND_IF_SOURCE_GENERATION_ERROR*_COMPOSE_IF_METAGENERATION_LIST_DEPRECATED,_COMPOSE_IF_SOURCE_GENERATION_MISMATCH_ERRORziprArLrrScopyr~r_post_resourcerxr)rTsourcesr{rrrif_source_generation_matchr sources_lenrsource_objectssourcesource_generation source_object preconditionsrequest api_responses rWcompose Blob.compose sJ$: ;g,K))&1FL-t44 :&  .9$R.A*&*#1488 >&  +/')1.2Vk-A*-.+= !MNNN-0-U))/FDUDU V " $09J"56 ;H"78%%m4.V"0#//446G   ,.2.?.? ]+ ,$7(?  "0099+X&)# 1L   .K< ; ;s FF!! F/c [SS9 URU5n[UR5nUR [URSS95 UR nSU;aUS U(aX/S'UR (aUR US'URbS UR;aURUS '[UUUUUUU U U S 9 URS UR3nURUURUUU U US 9n[US5n[US5nUS(a"URUS5 SUU4sSSS5 $USUU4sSSS5 $!,(df  g=f)a Rewrite source blob into this one. If :attr:`user_project` is set on the bucket, bills the API request to that project. .. note:: ``rewrite`` is not supported in a ``Batch`` context. :type source: :class:`Blob` :param source: blob whose contents will be rewritten into this blob. :type token: str :param token: (Optional) Token returned from an earlier, not-completed call to rewrite the same source blob. If passed, result will include updated status, total bytes written. :type client: :class:`~google.cloud.storage.client.Client` :param client: (Optional) The client to use. If not passed, falls back to the ``client`` stored on the blob's bucket. :type if_generation_match: long :param if_generation_match: (Optional) See :ref:`using-if-generation-match` Note that the generation to be matched is that of the ``destination`` blob. :type if_generation_not_match: long :param if_generation_not_match: (Optional) See :ref:`using-if-generation-not-match` Note that the generation to be matched is that of the ``destination`` blob. :type if_metageneration_match: long :param if_metageneration_match: (Optional) See :ref:`using-if-metageneration-match` Note that the metageneration to be matched is that of the ``destination`` blob. :type if_metageneration_not_match: long :param if_metageneration_not_match: (Optional) See :ref:`using-if-metageneration-not-match` Note that the metageneration to be matched is that of the ``destination`` blob. :type if_source_generation_match: long :param if_source_generation_match: (Optional) Makes the operation conditional on whether the source object's generation matches the given value. :type if_source_generation_not_match: long :param if_source_generation_not_match: (Optional) Makes the operation conditional on whether the source object's generation does not match the given value. :type if_source_metageneration_match: long :param if_source_metageneration_match: (Optional) Makes the operation conditional on whether the source object's current metageneration matches the given value. :type if_source_metageneration_not_match: long :param if_source_metageneration_not_match: (Optional) Makes the operation conditional on whether the source object's current metageneration does not match the given value. :type timeout: float or tuple :param timeout: (Optional) The amount of time, in seconds, to wait for the server response. See: :ref:`configuring_timeouts` :type retry: google.api_core.retry.Retry or google.cloud.storage.retry.ConditionalRetryPolicy :param retry: (Optional) How to retry the RPC. The default value is ``DEFAULT_RETRY_IF_GENERATION_SPECIFIED``, a conditional retry policy which will only enable retries if ``if_generation_match`` or ``generation`` is set, in order to ensure requests are idempotent before retrying them. Change the value to ``DEFAULT_RETRY`` or another `google.api_core.retry.Retry` object to enable retries regardless of generation precondition setting. See [Configuring Retries](https://cloud.google.com/python/docs/reference/storage/latest/retry_timeout). :rtype: tuple :returns: ``(token, bytes_rewritten, total_bytes)``, where ``token`` is a rewrite token (``None`` if the rewrite is complete), ``bytes_rewritten`` is the number of bytes rewritten so far, and ``total_bytes`` is the total number of bytes to be rewritten. zStorage.Blob.rewriterHT)rrL rewriteTokensourceGenerationNrfdestinationKmsKeyName)rrrrrif_source_generation_not_matchif_source_metageneration_match"if_source_metageneration_not_matchz /rewriteTortotalBytesRewritten objectSizedoner)r$rrrRrrrLrJrrxrrSintr)rTrtokenr{rrrrrrrrrrrrrxr rewrittenrts rWrewrite Blob.rewrite_sR$: ;))&1F-d.B.BCG NN263I3IRVW X--L|+ ./4^,  393D3D /0!!-'t/@/@@8<8I8I 45 ,$7(?(?,G+E/M/M3U kk]*TYYK8D!00  )#1LL)>?@I|L12D F#$$\*%=>Y,q< ;t /D@u< ; ;sD?E$E$$ E2c [SS9 URSU5 URUUUUUUUU U U U S9 un nU b#URUU UUUUUUU U U U S9 un nU bM#SSS5 g!,(df  g=f)a Update blob's storage class via a rewrite-in-place. This helper will wait for the rewrite to complete before returning, so it may take some time for large files. See https://cloud.google.com/storage/docs/per-object-storage-class If :attr:`user_project` is set on the bucket, bills the API request to that project. :type new_class: str :param new_class: new storage class for the object. One of: :attr:`~google.cloud.storage.constants.NEARLINE_STORAGE_CLASS`, :attr:`~google.cloud.storage.constants.COLDLINE_STORAGE_CLASS`, :attr:`~google.cloud.storage.constants.ARCHIVE_STORAGE_CLASS`, :attr:`~google.cloud.storage.constants.STANDARD_STORAGE_CLASS`, :attr:`~google.cloud.storage.constants.MULTI_REGIONAL_LEGACY_STORAGE_CLASS`, or :attr:`~google.cloud.storage.constants.REGIONAL_LEGACY_STORAGE_CLASS`. :type client: :class:`~google.cloud.storage.client.Client` :param client: (Optional) The client to use. If not passed, falls back to the ``client`` stored on the blob's bucket. :type if_generation_match: long :param if_generation_match: (Optional) See :ref:`using-if-generation-match` Note that the generation to be matched is that of the ``destination`` blob. :type if_generation_not_match: long :param if_generation_not_match: (Optional) See :ref:`using-if-generation-not-match` Note that the generation to be matched is that of the ``destination`` blob. :type if_metageneration_match: long :param if_metageneration_match: (Optional) See :ref:`using-if-metageneration-match` Note that the metageneration to be matched is that of the ``destination`` blob. :type if_metageneration_not_match: long :param if_metageneration_not_match: (Optional) See :ref:`using-if-metageneration-not-match` Note that the metageneration to be matched is that of the ``destination`` blob. :type if_source_generation_match: long :param if_source_generation_match: (Optional) Makes the operation conditional on whether the source object's generation matches the given value. :type if_source_generation_not_match: long :param if_source_generation_not_match: (Optional) Makes the operation conditional on whether the source object's generation does not match the given value. :type if_source_metageneration_match: long :param if_source_metageneration_match: (Optional) Makes the operation conditional on whether the source object's current metageneration matches the given value. :type if_source_metageneration_not_match: long :param if_source_metageneration_not_match: (Optional) Makes the operation conditional on whether the source object's current metageneration does not match the given value. :type timeout: float or tuple :param timeout: (Optional) The amount of time, in seconds, to wait for the server response. See: :ref:`configuring_timeouts` :type retry: google.api_core.retry.Retry or google.cloud.storage.retry.ConditionalRetryPolicy :param retry: (Optional) How to retry the RPC. The default value is ``DEFAULT_RETRY_IF_GENERATION_SPECIFIED``, a conditional retry policy which will only enable retries if ``if_generation_match`` or ``generation`` is set, in order to ensure requests are idempotent before retrying them. Change the value to ``DEFAULT_RETRY`` or another `google.api_core.retry.Retry` object to enable retries regardless of generation precondition setting. See [Configuring Retries](https://cloud.google.com/python/docs/reference/storage/latest/retry_timeout). zStorage.Blob.updateStorageClassrHrC) rrrrrrrrrrN) rrrrrrrrrrr)r$_patch_propertyr)rT new_classr{rrrrrrrrrrrrRs rWupdate_storage_classBlob.update_storage_classsH$E F   ;,,$7(?(?,G+E/M/M3U' KE1a#"ll(;,C,C0K/I3Q3Q7Y#+  q!#%G F Fs AA)) A7c H[SS9 US:XaIU(dU(dU(a [S5eU(a [S5e[U4SU0UD6sSSS5 $US:Xa7U(dU(dU(a [S5e[U4X#S .UD6sSSS5 $US ;a3U(a [S5e[ [U4SU0UD6UUUS 9sSSS5 $US ;a2US La [S5e[ [U4USS .UD6UUUS 9sSSS5 $[ S5e!,(df  g=f)aCreate a file handler for file-like I/O to or from this blob. This method can be used as a context manager, just like Python's built-in 'open()' function. While reading, as with other read methods, if blob.generation is not set the most recent blob generation will be used. Because the file-like IO reader downloads progressively in chunks, this could result in data from multiple versions being mixed together. If this is a concern, use either bucket.get_blob(), or blob.reload(), which will download the latest generation number and set it; or, if the generation is known, set it manually, for instance with bucket.blob(generation=123456). Checksumming (hashing) to verify data integrity is disabled for reads using this feature because reads are implemented using request ranges, which do not provide checksums to validate. See https://cloud.google.com/storage/docs/hashes-etags for details. See a [code sample](https://github.com/googleapis/python-storage/blob/main/samples/snippets/storage_fileio_write_read.py). Keyword arguments to pass to the underlying API calls. For both uploads and downloads, the following arguments are supported: - ``if_generation_match`` - ``if_generation_not_match`` - ``if_metageneration_match`` - ``if_metageneration_not_match`` - ``timeout`` - ``retry`` For downloads only, the following additional arguments are supported: - ``raw_download`` For uploads only, the following additional arguments are supported: - ``content_type`` - ``predefined_acl`` - ``checksum`` :type mode: str :param mode: (Optional) A mode string, as per standard Python `open()` semantics.The first character must be 'r', to open the blob for reading, or 'w' to open it for writing. The second character, if present, must be 't' for (unicode) text mode, or 'b' for bytes mode. If the second character is omitted, text mode is the default. :type chunk_size: long :param chunk_size: (Optional) For reads, the minimum number of bytes to read at a time. If fewer bytes than the chunk_size are requested, the remainder is buffered. For writes, the maximum number of bytes to buffer before sending data to the server, and the size of each request when data is sent. Writes are implemented as a "resumable upload", so chunk_size for writes must be exactly a multiple of 256KiB as with other resumable uploads. The default is 40 MiB. :type ignore_flush: bool :param ignore_flush: (Optional) For non text-mode writes, makes flush() do nothing instead of raising an error. flush() without closing is not supported by the remote service and therefore calling it normally results in io.UnsupportedOperation. However, that behavior is incompatible with some consumers and wrappers of file objects in Python, such as zipfile.ZipFile or io.TextIOWrapper. Setting ignore_flush will cause flush() to successfully do nothing, for compatibility with those contexts. The correct way to actually flush data to the remote server is to close() (using a context manager, such as in the example, will cause this to happen automatically). :type encoding: str :param encoding: (Optional) For text mode only, the name of the encoding that the stream will be decoded or encoded with. If omitted, it defaults to locale.getpreferredencoding(False). :type errors: str :param errors: (Optional) For text mode only, an optional string that specifies how encoding and decoding errors are to be handled. Pass 'strict' to raise a ValueError exception if there is an encoding error (the default of None has the same effect), or pass 'ignore' to ignore errors. (Note that ignoring encoding errors can lead to data loss.) Other more rarely-used options are also available; see the Python 'io' module documentation for 'io.TextIOWrapper' for a complete list. :type newline: str :param newline: (Optional) For text mode only, controls how line endings are handled. It can be None, '', '\n', '\r', and '\r\n'. If None, reads use "universal newline mode" and writes use the system default. See the Python 'io' module documentation for 'io.TextIOWrapper' for details. :returns: A 'BlobReader' or 'BlobWriter' from 'google.cloud.storage.fileio', or an 'io.TextIOWrapper' around one of those classes, depending on the 'mode' argument. zStorage.Blob.openrHrz=encoding, errors and newline arguments are for text mode onlyz5ignore_flush argument is for non-text write mode onlyrONr))rO ignore_flush)rrt)rJerrorsnewline)wwtFzIignore_flush is required for text mode writing and cannot be set to FalseTzFSupported modes strings are 'r', 'rb', 'rt', 'w', 'wb', and 'wt' only.)r$rbr4r5rNotImplementedError)rTmoderOrrJrrr1s rWr* Blob.openshZ$7 8t|v$W $O"$H:HH9 8v$W"%/NT!9 8&$$O%tE EfE%!# 19 8<$5($1%)3$JP&!# I9 8Z*\[9 8s$AD3D/D.D D D!r9r:r;r<r=c [U[5(aUU S.nURUS9nURU5nUR UUU U U S9n[ UR 5nSUS'[UUUS9 0[URRUS9EUEUREnURnURUUUUUUUU U US9 g ![an[U5 S nAg S nAff=f) ap Download the contents of a blob object into a file-like object. See https://cloud.google.com/storage/docs/downloading-objects If :attr:`user_project` is set on the bucket, bills the API request to that project. :type file_obj: file :param file_obj: A file handle to which to write the blob's data. :type client: :class:`~google.cloud.storage.client.Client` :param client: (Optional) The client to use. If not passed, falls back to the ``client`` stored on the blob's bucket. :type start: int :param start: (Optional) The first byte in a range to be downloaded. :type end: int :param end: (Optional) The last byte in a range to be downloaded. :type raw_download: bool :param raw_download: (Optional) If true, download the object without any expansion. :type if_etag_match: Union[str, Set[str]] :param if_etag_match: (Optional) See :ref:`using-if-etag-match` :type if_etag_not_match: Union[str, Set[str]] :param if_etag_not_match: (Optional) See :ref:`using-if-etag-not-match` :type if_generation_match: long :param if_generation_match: (Optional) See :ref:`using-if-generation-match` :type if_generation_not_match: long :param if_generation_not_match: (Optional) See :ref:`using-if-generation-not-match` :type if_metageneration_match: long :param if_metageneration_match: (Optional) See :ref:`using-if-metageneration-match` :type if_metageneration_not_match: long :param if_metageneration_not_match: (Optional) See :ref:`using-if-metageneration-not-match` :type timeout: float or tuple :param timeout: (Optional) The amount of time, in seconds, to wait for the server response. See: :ref:`configuring_timeouts` :type checksum: str :param checksum: (Optional) The type of checksum to compute to verify the integrity of the object. The response headers must contain a checksum of the requested type. If the headers lack an appropriate checksum (for instance in the case of transcoded or ranged downloads where the remote service does not know the correct checksum, including downloads where chunk_size is set) an INFO-level log will be emitted. Supported values are "md5", "crc32c", "auto" and None. The default is "auto", which will try to detect if the C extension for crc32c is installed and fall back to md5 otherwise. :type retry: google.api_core.retry.Retry or google.cloud.storage.retry.ConditionalRetryPolicy :param retry: (Optional) How to retry the RPC. A None value will disable retries. A google.api_core.retry.Retry value will enable retries, and the object will define retriable response codes and errors and configure backoff and timeout options. A google.cloud.storage.retry.ConditionalRetryPolicy value wraps a Retry object and activates it only if certain conditions are met. This class exists to provide safe defaults for RPC calls that are not technically safe to retry normally (due to potential data duplication or other side-effects) but become safe to retry if a condition such as if_metageneration_match is set. See the retry.py source code and docstrings in this package (google.cloud.storage.retry) for information on retry types and how to configure them. :type command: str :param command: (Optional) Information about which interface for download was used, to be included in the X-Goog-API-Client header. Please leave as None unless otherwise directed. rrrgzipzaccept-encodingrr^)rr rN)rr0rrrrrRrrrr`rarr r/r)rTrr{r r rrrrrrrrr rr_rrrrrs rWr$Blob._prep_and_do_downloadds1X e3 4 4 &9)@L<<,<WE%%f---  3$;$;(C . *$*>*>?%+!" '/  "6#5#5#@#@'R  ##  LL  .   !   . ( - - .s.C C& C!!C&cVURRS5nUb [U5$g)aNumber of underlying components that make up this object. See https://cloud.google.com/storage/docs/json_api/v1/objects :rtype: int or ``NoneType`` :returns: The component count (in case of a composed object) or ``None`` if the blob's resource has not been loaded from the server. This property will not be set on objects not created via ``compose``. componentCountNrSrr)rTcomponent_counts rWrBlob.component_counts1**../?@  &' ' 'rYc8URRS5$)aLRetrieve the ETag for the object. See [`RFC 2616 (etags)`](https://tools.ietf.org/html/rfc2616#section-3.11) and [`API reference docs`](https://cloud.google.com/storage/docs/json_api/v1/objects). :rtype: str or ``NoneType`` :returns: The blob etag or ``None`` if the blob's resource has not been loaded from the server. rrSrr[s rWr Blob.etags##F++rYeventBasedHoldcVURRS5nUb [U5$g)zRetrieve the generation for the object. See https://cloud.google.com/storage/docs/json_api/v1/objects :rtype: int or ``NoneType`` :returns: The generation of the blob or ``None`` if the blob's resource has not been loaded from the server. rLNr)rTrLs rWrLBlob.generation+s/%%)),7  !z? " "rYc8URRS5$)a4Retrieve the ID for the object. See https://cloud.google.com/storage/docs/json_api/v1/objects The ID consists of the bucket name, object name, and generation number. :rtype: str or ``NoneType`` :returns: The ID of the blob or ``None`` if the blob's resource has not been loaded from the server. idrr[s rWrBlob.id9s##D))rYr?c8URRS5$)aRetrieve the media download URI for the object. See https://cloud.google.com/storage/docs/json_api/v1/objects :rtype: str or ``NoneType`` :returns: The media link for the blob or ``None`` if the blob's resource has not been loaded from the server. mediaLinkrr[s rWrBlob.media_linkUs##K00rYc`[R"URRS55$)aRetrieve arbitrary/application specific metadata for the object. See https://cloud.google.com/storage/docs/json_api/v1/objects :setter: Update arbitrary/application specific metadata for the object. :getter: Retrieve arbitrary/application specific metadata for the object. :rtype: dict or ``NoneType`` :returns: The metadata associated with the blob or ``None`` if the property is not set. r@rdeepcopyrSrr[s rWr@ Blob.metadataas$}}T--11*=>>rYcUb2UR5VVs0sHup#X#b [U5OS_M nnnURSU5 gs snnf)aUpdate arbitrary/application specific metadata for the object. Values are stored to GCS as strings. To delete a key, set its value to None and call blob.patch(). See https://cloud.google.com/storage/docs/json_api/v1/objects :type value: dict :param value: The blob metadata to set. Nr@)itemsstrr)rTrdkvs rWr@r#rsI  FKkkmTmdaQ-AT9mET Z/UsA cVURRS5nUb [U5$g)aRetrieve the metageneration for the object. See https://cloud.google.com/storage/docs/json_api/v1/objects :rtype: int or ``NoneType`` :returns: The metageneration of the blob or ``None`` if the blob's resource has not been loaded from the server. rNr)rTrs rWrBlob.metagenerations1))--.>?  %~& & &rYc`[R"URRS55$)aRetrieve info about the owner of the object. See https://cloud.google.com/storage/docs/json_api/v1/objects :rtype: dict or ``NoneType`` :returns: Mapping of owner's role/ID, or ``None`` if the blob's resource has not been loaded from the server. ownerr!r[s rWr, Blob.owners$}}T--11':;;rYcVURRS5nUb [U5$g)a/Retrieve timestamp at which the object's retention period expires. See https://cloud.google.com/storage/docs/json_api/v1/objects :rtype: :class:`datetime.datetime` or ``NoneType`` :returns: Datetime object parsed from RFC3339 valid timestamp, or ``None`` if the property is not set locally. retentionExpirationTimeNrSrrrcs rWretention_expiration_timeBlob.retention_expiration_times1  $$%>?  -e4 4 rYc8URRS5$)zRetrieve the URI for the object. See https://cloud.google.com/storage/docs/json_api/v1/objects :rtype: str or ``NoneType`` :returns: The self link for the blob or ``None`` if the blob's resource has not been loaded from the server. selfLinkrr[s rW self_linkBlob.self_links##J//rYcVURRS5nUb [U5$g)zSize of the object, in bytes. See https://cloud.google.com/storage/docs/json_api/v1/objects :rtype: int or ``NoneType`` :returns: The size of the blob or ``None`` if the blob's resource has not been loaded from the server. rtNr)rTrts rWrt Blob.sizes/##F+  t9  rYc8URRS5$)zResource name of Cloud KMS key used to encrypt the blob's contents. :rtype: str or ``NoneType`` :returns: The resource name or ``None`` if no Cloud KMS key was used, or the blob's resource has not been loaded from the server. rKrr[s rWrJBlob.kms_key_names##L11rYc(URSU5 g)zSet KMS encryption key for object. :type value: str or ``NoneType`` :param value: new KMS key name (None to clear any existing key). rKN)rrcs rWrJr:s \51rYrC temporaryHoldcVURRS5nUb [U5$g)aRetrieve the timestamp at which the object was deleted. See https://cloud.google.com/storage/docs/json_api/v1/objects :rtype: :class:`datetime.datetime` or ``NoneType`` :returns: Datetime object parsed from RFC3339 valid timestamp, or ``None`` if the blob's resource has not been loaded from the server (see :meth:`reload`). If the blob has not been deleted, this will never be set. timeDeletedNr0rcs rW time_deletedBlob.time_deleteds0  $$]3  -e4 4 rYcVURRS5nUb [U5$g)a[Retrieve the timestamp at which the object was created. See https://cloud.google.com/storage/docs/json_api/v1/objects :rtype: :class:`datetime.datetime` or ``NoneType`` :returns: Datetime object parsed from RFC3339 valid timestamp, or ``None`` if the blob's resource has not been loaded from the server (see :meth:`reload`). timeCreatedNr0rcs rW time_createdBlob.time_created s0  $$]3  -e4 4 rYcVURRS5nUb [U5$g)a[Retrieve the timestamp at which the object was updated. See https://cloud.google.com/storage/docs/json_api/v1/objects :rtype: :class:`datetime.datetime` or ``NoneType`` :returns: Datetime object parsed from RFC3339 valid timestamp, or ``None`` if the blob's resource has not been loaded from the server (see :meth:`reload`). r-Nr0rcs rWr- Blob.updateds0  $$Y/  -e4 4 rYcVURRS5nUb [U5$g)aLRetrieve the custom time for the object. See https://cloud.google.com/storage/docs/json_api/v1/objects :rtype: :class:`datetime.datetime` or ``NoneType`` :returns: Datetime object parsed from RFC3339 valid timestamp, or ``None`` if the blob's resource has not been loaded from the server (see :meth:`reload`). r>Nr0rcs rW custom_timeBlob.custom_time's0  $$\2  -e4 4 rYcDUb [U5nURSU5 g)aSet the custom time for the object. Once set on the server side object, this value can't be unset, but may only changed to a custom datetime in the future. If :attr:`custom_time` must be unset, either perform a rewrite operation or upload the data again. See https://cloud.google.com/storage/docs/json_api/v1/objects :type value: :class:`datetime.datetime` :param value: new value Nr>)rrrcs rWrHrI6s$  (/E \51rYcdURRS05n[RX5$)zRetrieve the retention configuration for this object. :rtype: :class:`Retention` :returns: an instance for managing the object's retention configuration. rB)rSr Retentionr)rTrs rWrBBlob.retentionJs-##K4&&t22rYcVURRS5nUb [U5$g)aIf this object has been soft-deleted, returns the time at which it became soft-deleted. :rtype: :class:`datetime.datetime` or ``NoneType`` :returns: (readonly) The time that the object became soft-deleted. Note this property is only set for soft-deleted objects. softDeleteTimeNr0)rTsoft_delete_times rWrPBlob.soft_delete_timeT3 ++//0@A  '-.>? ? (rYcVURRS5nUb [U5$g)a If this object has been soft-deleted, returns the time at which it will be permanently deleted. :rtype: :class:`datetime.datetime` or ``NoneType`` :returns: (readonly) The time that the object will be permanently deleted. Note this property is only set for soft-deleted objects. hardDeleteTimeNr0)rThard_delete_times rWrUBlob.hard_delete_timearRrY)rQrPr^rRrO)NNNN)N)NNGETNNNNNNNNNNNNFNhttp)NN)rNNNNN)j__name__ __module__ __qualname____firstlineno____doc__r^rar-r+r)r(r*r,STORAGE_CLASSESrNpropertyrUrOsetterrI staticmethodrmrprurxr{r~rrr classmethodrrrr'r1rrrrrr r%r3r6r;r@rLrSrZrbrxrrrrrrrrrrr2rrrrr3rrrr*r cache_controlcontent_dispositioncontent_encodingcontent_languagerrr=r$rrevent_based_holdrLrmd5_hashrr@rr,r1r5rtrJ storage_classtemporary_holdr?rCr-rHrBrPrU__static_attributes__ __classcell__rVs@rWrErEs5 DK%D +% O 8>   ! !$$ % % 7 7H = =""((=  &77<55< !"""'` H $ $$( j\ $ $$( IV&! $ $$( 9Av(C`  FLV  $ $$( AF4<  $ $$( wv  $ $$( v,t  $ $$( j\  $ $$( s(j<B#6`!lh $ $$( !z!N!Jn!_H  $ $$( Z.~  $ $$( M^6 $ $$( y|" $ $$( tp   $ $$(r2l!%  C.P + <.~#'0@ 5/r  $ $$(4p  $ $$(4r  $#'3J/^ $ $$(#''+'++/ 3cAP $ $$(#''+'++/ 3DP\|%^4M++?@((9:((9:$$78Lh 'F    $ $$( !^.@ ( ( , ,((89 # # * * *H  1 1?? __ 0 0 ' ' < < 5 5 0 0  2222%^4M,&o6N 5 5 5 5 5 5 5 522&33 @ @ @ @rYrEc\[US5(d UR$UR5$)zReturns the host name from the given connection. :type connection: :class:`~google.cloud.storage._http.Connection` :param connection: The connection object. :rtype: str :returns: The host name. get_api_base_url_for_mtls)hasattr API_BASE_URLro) connections rWrros5z#>??  1 1 3rYc Uc0$[U5n[R"U5R5n[R "U5n[R "U5nU(aSnOSnUS-SUS-[ U5US-[ U50$)aKBuilds customer encryption key headers :type key: bytes :param key: 32 byte key to build request key and hash. :type source: bool :param source: If true, return headers for the "source" blob; otherwise, return headers for the "destination" blob. :rtype: dict :returns: dict of HTTP headers being sent in request. zX-Goog-Copy-Source-Encryption-zX-Goog-Encryption- AlgorithmAES256Keyz Key-Sha256)rhashlibsha256rbase64 b64encoder)rYrkey_hashprefixs rWrrs { C.C~~c"))+H)H   3 C 1% h)#.0: rYc([USS9n[XS9$)aURL-quote a string. If the value is unicode, this method first UTF-8 encodes it as bytes and then quotes the bytes. (In Python 3, ``urllib.parse.quote`` does this encoding automatically, but in Python 2, non-ASCII characters cannot be quoted.) :type value: str or bytes :param value: The value to be URL-quoted. :type safe: bytes :param safe: Bytes *not* to be quoted. By default, includes only ``b'~'``. :rtype: str :returns: The encoded value (bytes in Python 2, unicode in Python 3). rErr)rr)rdrs rWrjrjs" eg .E  ""rYcTU(a!URS[R5 gg)zRewind the stream if desired. :type stream: IO[bytes] :param stream: A bytes IO object open for reading. :type rewind: bool :param rewind: Indicates if we should seek to the beginning of the stream. rN)seekr+SEEK_SET)r rs rWrrs Ar{{#rYc,URnUR(aURS-[U5-nO [U5nURRSURR SU3n[ R"URX1S9e)aCRe-wrap and raise an ``InvalidResponse`` exception. :type error: :exc:`google.cloud.storage.exceptions.InvalidResponse` :param error: A caught exception from the ``google-resumable-media`` library. :raises: :class:`~google.cloud.exceptions.GoogleCloudError` corresponding to the failed status code z:  )r) rtextr&rrurlrfrom_http_status status_code)errorr error_messagemessages rWrrs~~H}} ,s5z9 E !!(()8+;+;+?+?*@=/RG  % %h&:&:G WWrYc[U5S:XaU$[U5up#pEn[U5nURU5 [ X#U[ U5U45$)aIAdd one query parameter to a base URL. :type base_url: string :param base_url: Base URL (may already contain query parameters) :type name_value_pairs: list of (string, string) tuples. :param name_value_pairs: Names and values of the query parameters to add :rtype: string :returns: URL with additional query strings appended. r)ror rextendr r)rrrnetlocrxqueryfrags rWrrsX !(0(:%FD e E LL!" vtYu-=tD EErYc^\rSrSrSrS U4Sjjr\S5r\S5r \S5r \ RS5r \S5r \ RS 5r \S 5r S rU=r$) rLiaMap an object's retention configuration. :type blob: :class:`Blob` :params blob: blob for which this retention configuration applies to. :type mode: str or ``NoneType`` :params mode: (Optional) The mode of the retention configuration, which can be either Unlocked or Locked. See: https://cloud.google.com/storage/docs/object-lock :type retain_until_time: :class:`datetime.datetime` or ``NoneType`` :params retain_until_time: (Optional) The earliest time that the object can be deleted or replaced, which is the retention configuration set for this object. :type retention_expiration_time: :class:`datetime.datetime` or ``NoneType`` :params retention_expiration_time: (Optional) The earliest time that the object can be deleted, which depends on any retention configuration set for the object and any retention policy set for the bucket that contains the object. This value should normally only be set by the back-end API. c>SU0nUb [U5nX5S'Ub [U5nXES'[[U]U5 Xlg)Nr retainUntilTimer/)rrMrLrN_blob)rTblobr retain_until_timer1rKrVs rWrNRetention.__init__ sX~  ( 45F G "3  $ 0(<=V(W %*C &' i'- rYc8U"U5nURU5 U$)a,Factory: construct instance from resource. :type blob: :class:`Blob` :params blob: Blob for which this retention configuration applies to. :type resource: dict :param resource: mapping as returned from API call. :rtype: :class:`Retention` :returns: Retention configuration created from resource. )r)rrrinstances rWrRetention.from_api_reprst9!rYcUR$)znBlob for which this retention configuration applies to. :rtype: :class:`Blob` :returns: the instance's blob. rr[s rWrRetention.blob-szzrYc$URS5$)zThe mode of the retention configuration. Options are 'Unlocked' or 'Locked'. :rtype: string :returns: The mode of the retention configuration, which can be either set to 'Unlocked' or 'Locked'. r )rr[s rWr Retention.mode6sxxrYcDXS'URRSU5 g)Nr rB)rrrcs rWr r?sV  !!+t4rYcBURS5nUb [U5$g)a\The earliest time that the object can be deleted or replaced, which is the retention configuration set for this object. :rtype: :class:`datetime.datetime` or ``NoneType`` :returns: Datetime object parsed from RFC3339 valid timestamp, or ``None`` if the blob's resource has not been loaded from the server (see :meth:`reload`). rNrrrcs rWrRetention.retain_until_timeDs)*+  -e4 4 rYc`Ub [U5nXS'URRSU5 g)zSet the retain_until_time for the object retention configuration. :type value: :class:`datetime.datetime` :param value: The earliest time that the object can be deleted or replaced. NrrB)rrrrcs rWrrRs1  (/E"'  !!+t4rYcBURS5nUb [U5$g)a7The earliest time that the object can be deleted, which depends on any retention configuration set for the object and any retention policy set for the bucket that contains the object. :rtype: :class:`datetime.datetime` or ``NoneType`` :returns: (readonly) The earliest time that the object can be deleted. r/Nr)rTr1s rWr1#Retention.retention_expiration_time^s+%)HH-F$G! $ 0-.GH H 1rYr)NNN)rYrZr[r\r]rNrbrr_rr r`rr1rkrlrms@rWrLrLs2"& &    [[55 5 5 5 5 I IrYrL)F)~)kr]ryrrwiorrloggingrOr+r email.parserr urllib.parserrrr r r$google.cloud.storage._media.requestsr r r rrrgoogle.api_core.iamr google.cloudrgoogle.cloud._helpersrrrrgoogle.cloud.exceptionsrgoogle.cloud.storage._helpersrrrrrrrrgoogle.cloud.storage._signingr r!r"r#+google.cloud.storage._opentelemetry_tracingr$google.cloud.storage.aclr%r&google.cloud.storage.constantsr'r(r)r*r+r,r-google.cloud.storage.exceptionsr.r/google.cloud.storage.retryr0r1r2r3google.cloud.storage.fileior4r5rQr_BASE_UPLOAD_TEMPLATErrr~rrWrprrrrrr?rcompilerr}r getLoggerrYrrErrrjrrrrHrLrYrWrs"  %""!#@9<C@@&#36<+,AJ8:DE>G@@6HI(.;@ANAHA:;=4DL223TH0+=/+=$    Y,# 5' L; +O-, # I   H %UG@>UG@pN&B#* $X0F*xIxIrY