
    o[we                         d dl mZ d dlZd dlmZ d Zej        j        d             Zej        j        d             Z	dS )    )BytesION)read_csvc                      t          j        dd           ddlm}  ddg}|D ]8} | t	          |          t          |                    }t          |           9d S )	Nbotocorez1.10.47)
minversionr   )StreamingBodys   foo,bar,baz
1,2,3
4,5,6
s   just,the,header
)content_length)pytestimportorskipbotocore.responser   r   lenr   )r   dataelbodys       7lib/python3.11/site-packages/pandas/tests/io/test_s3.pytest_streaming_s3_objectsr      s}     
y9999//////*,@AD  }WR[[RAAA     c                     t          j        d           t          d| j         dd|          }t	          |          dk    sJ d S )Ns3fss3://	/tips.csv   )nrowsstorage_options)r
   r   r   namer   )s3_public_bucket_with_datas3soresults      r   'test_read_without_creds_from_pub_bucketr      s`     :*/:::  F
 v;;!r   c                     t          j        d           |                    dd           |                    dd           t          d| j         ddd |	          }t          |          dk    sJ d S )
Nr   AWS_ACCESS_KEY_ID
foobar_keyAWS_SECRET_ACCESS_KEYfoobar_secretr   r      )r   headerr   )r
   r   setenvr   r   r   )r   monkeypatchr   dfs       r   $test_read_with_creds_from_pub_bucketr*       s     *L999.@@@	:*/:::	
 
 
B r77a<<<<<<r   )
ior   r
   pandasr   r   mark
single_cpur   r*    r   r   <module>r0      s                	 	 	        r   