/usr/local/lib64/python3.6/site-packages/pyarrow/tests/parquet/__pycache__
Edit: /usr/local/lib64/python3.6/site-packages/pyarrow/tests/parquet/__pycache__/conftest.cpython-36.pyc (1794B)
3
9%Eg @ sV d dl Z d dlmZ e jdddd Ze jdd Ze jd d
Ze jdd ZdS )
N)guidmodule)Zscopec C s | d S )NZparquet )Zbase_datadirr r J/usr/local/lib64/python3.6/site-packages/pyarrow/tests/parquet/conftest.pydatadir s r c C s| t jd}t jd}| d \}}}}|jddj|||||jjdddd }|jd
}y|j W n tk
rv Y nX d
S )Nboto3botocore
connections3zhttp://{}:{}Zs3v4)Zsignature_versionz us-east-1)endpoint_urlZaws_access_key_idZaws_secret_access_keyconfigZregion_namez test-s3fs) pytestimportorskipresourceformatclientZConfigZBucketcreate Exception) s3_serverr r hostport
access_key
secret_keyr
Zbucketr r r s3_bucket s
r c c s t jd}| d \}}}}|j||ddj||id}dj|t }|j| ||fV y|j|dd W n tk
r~ Y nX d S ) Ns3fsr r zhttp://{}:{})keysecretZ
client_kwargsz{}/{}T) recursive)r
r ZS3FileSystemr r mkdirZrmFileNotFoundError) r r r r r r r fsZ test_pathr r r s3_example_s3fs3 s
r! c c sT ddl m} | d \}}}}dj||||}|j|\}}|jd |||fV d S )Nr )
FileSystemr zDs3://{}:{}@mybucket/data.parquet?scheme=http&endpoint_override={}:{}Zmybucket)Z
pyarrow.fsr" r Zfrom_uriZ
create_dir) r r" r r r r urir pathr r r
s3_example_fsJ s
r% )r
Zpyarrow.utilr Zfixturer r r! r% r r r r
s