
    dha                     b    S SK r S SKJr  S SKJrJr  S SKJr  S SKJ	r	  S SK
Jr   " S S\5      rg)	    N)Path)ListUnion)Document)stringify_dict)
BaseLoaderc                   D    \ rS rSrSrS\\\4   4S jrS\	\
   4S jrSrg)	AirbyteJSONLoader   z Load local `Airbyte` json files.	file_pathc                     Xl         g)zJInitialize with a file path. This should start with '/tmp/airbyte_local/'.Nr   )selfr   s     i/var/www/html/shao/venv/lib/python3.13/site-packages/langchain_community/document_loaders/airbyte_json.py__init__AirbyteJSONLoader.__init__   s
    ">    returnc                     Sn[        U R                  S5       H*  n[        R                  " U5      S   nU[	        U5      -  nM,     S[        U R                  5      0n[        XS9/$ )N r_airbyte_datasource)page_contentmetadata)openr   jsonloadsr   strr   )r   textlinedatar   s        r   loadAirbyteJSONLoader.load   sa    -D::d#O4DN4((D . c$..12d>??r   r   N)__name__
__module____qualname____firstlineno____doc__r   r   r   r   r   r   r#   __static_attributes__ r   r   r
   r
      s,    *?%T	"2 ?
@d8n @r   r
   )r   pathlibr   typingr   r   langchain_core.documentsr   langchain_core.utilsr   )langchain_community.document_loaders.baser   r
   r+   r   r   <module>r1      s%       - / @@
 @r   