a
    bga                     @   s\   d dl Z d dlmZ d dlmZmZ d dlmZ d dlm	Z	 d dl
mZ G dd deZdS )	    N)Path)ListUnion)Document)stringify_dict)
BaseLoaderc                   @   s8   e Zd ZdZeeef dddZee	 dddZ
dS )	AirbyteJSONLoaderz Load local `Airbyte` json files.	file_pathc                 C   s
   || _ dS )zJInitialize with a file path. This should start with '/tmp/airbyte_local/'.Nr	   )selfr
    r   /var/www/html/cobodadashboardai.evdpl.com/venv/lib/python3.9/site-packages/langchain_community/document_loaders/airbyte_json.py__init__   s    zAirbyteJSONLoader.__init__)returnc                 C   sL   d}t | jdD ]}t|d }|t|7 }qdt| ji}t||dgS )N rZ_airbyte_datasource)Zpage_contentmetadata)openr
   jsonloadsr   strr   )r   textlinedatar   r   r   r   load   s    zAirbyteJSONLoader.loadN)__name__
__module____qualname____doc__r   r   r   r   r   r   r   r   r   r   r   r      s   r   )r   pathlibr   typingr   r   Zlangchain_core.documentsr   Zlangchain_core.utilsr   Z)langchain_community.document_loaders.baser   r   r   r   r   r   <module>   s   