:py:mod:`astronomer.providers.microsoft.azure.hooks.wasb`
=========================================================

.. py:module:: astronomer.providers.microsoft.azure.hooks.wasb

.. autoapi-nested-parse::

   This module contains the Azure WASB hook's asynchronous implementation.



Module Contents
---------------

Classes
~~~~~~~

.. autoapisummary::

   astronomer.providers.microsoft.azure.hooks.wasb.WasbHookAsync




Attributes
~~~~~~~~~~

.. autoapisummary::

   astronomer.providers.microsoft.azure.hooks.wasb.Credentials


.. py:data:: Credentials

   

.. py:class:: WasbHookAsync(wasb_conn_id = 'wasb_default', public_read = False)

   Bases: :py:obj:`airflow.providers.microsoft.azure.hooks.wasb.WasbHook`

   An async hook that connects to Azure WASB to perform operations.

   :param wasb_conn_id: reference to the :ref:`wasb connection <howto/connection:wasb>`
   :param public_read: whether an anonymous public read access should be used. default is False

   .. py:method:: get_conn()

      Return the async BlobServiceClient object.


   .. py:method:: check_for_blob_async(container_name, blob_name, **kwargs)
      :async:

      Check if a blob exists on Azure Blob Storage.

      :param container_name: name of the container
      :param blob_name: name of the blob
      :param kwargs: optional keyword arguments for ``BlobClient.get_blob_properties``


   .. py:method:: get_blobs_list_async(container_name, prefix = None, include = None, delimiter = '/', **kwargs)
      :async:

      List blobs in a given container.

      :param container_name: the name of the container
      :param prefix: filters the results to return only blobs whose names
          begin with the specified prefix.
      :param include: specifies one or more additional datasets to include in the
          response. Options include: ``snapshots``, ``metadata``, ``uncommittedblobs``,
          ``copy`, ``deleted``.
      :param delimiter: filters objects based on the delimiter (for e.g '.csv')


   .. py:method:: check_for_prefix_async(container_name, prefix, **kwargs)
      :async:

      Check if a prefix exists on Azure Blob storage.

      :param container_name: Name of the container.
      :param prefix: Prefix of the blob.
      :param kwargs: Optional keyword arguments for ``ContainerClient.walk_blobs``