
    Ng"                     J    d dl mZmZ d dlmZ d dlmZ  G d de          ZdS )    )AnyIterator)
BaseLoader)Documentc            
       F    e Zd ZdZdededededdf
dZdee         fd	Z	dS )
AirtableLoaderzLoad the `Airtable` tables.	api_tokentable_idbase_idkwargsreturnNc                 >    || _         || _        || _        || _        dS )a  Initialize with API token and the IDs for table and base.

        Args:
            api_token: Airtable API token.
            table_id: Airtable table ID.
            base_id:
            kwargs: Additional parameters to pass to Table.all(). Refer to the
                pyairtable documentation for available options:
                https://pyairtable.readthedocs.io/en/latest/api.html#pyairtable.Table.all
        N)r	   r
   r   r   )selfr	   r
   r   r   s        i/var/www/html/ai-engine/env/lib/python3.11/site-packages/langchain_community/document_loaders/airtable.py__init__zAirtableLoader.__init__
   s$     #     c              #   .  K   ddl m}  || j        | j        | j                  } |j        di | j        }|D ][}| j        dz   | j        z   | j        | j        d}d| j        v r| j        d         |d<   t          t          |          |          V  \dS )	zLazy load Documents from table.r   )Table_)sourcer   r
   view)page_contentmetadataN )	
pyairtabler   r	   r   r
   allr   r   str)r   r   tablerecordsrecordr   s         r   	lazy_loadzAirtableLoader.lazy_load   s       	%$$$$$dndlDMBB%)**dk** 		H 		HF,,t}<< M H
 $$#';v#6 FhGGGGGGG		H 		Hr   )
__name__
__module____qualname____doc__r   r   r   r   r   r!   r   r   r   r   r      s}        %%(+69EH	   $H8H- H H H H H Hr   r   N)typingr   r   langchain_core.document_loadersr   langchain_core.documentsr   r   r   r   r   <module>r)      s                    6 6 6 6 6 6 - - - - - -%H %H %H %H %HZ %H %H %H %H %Hr   