Ë
|
oñúh 0 ã óÒ d Z ddlmZ ddlZddlZddlZddlZddlm c m
|
Z ddl m Z ddlmZ ddlmZ ddlmZ ej* j- d« Zej* j0 ej* j2 ej* j5 dd d
|
g« ej* j5 d d d g« d « « « « Zej* j0 ej* j2 d « « Z ej: d « Z ej* j2 ej* j? d« e j@ « G d d« « « « Z!y)zl
|
Tests parsers ability to read and parse non-local files
|
and hence require a network connection to be read.
|
é )ÚBytesION)Ú DataFrame)Ú read_feather©Úread_csvz=ignore:Passing a BlockManager to DataFrame:DeprecationWarningÚmodeÚexplicitÚinferÚengineÚpythonÚcc óX |dk( rt j d« || }t |dddd|z « d« 5 }| j |j « ¬« d d d « | j
|
d z |z } |d
|
k7 r|}t | d ||¬ « }
|
t j |
|
|« y # 1 sw Y HxY w) NÚtarz5TODO: Add tar salaraies.csv to pandas/io/parsers/dataÚioÚparserÚdataz salaries.csvÚrb©Úcontentz /salaries.csvr ú )ÚsepÚ compressionr ) ÚpytestÚskipÚopenÚ serve_contentÚreadÚurlr ÚtmÚassert_frame_equal) Ú
|
httpserverÚdatapathÚsalaries_tabler r Úcompression_onlyÚcompression_to_extensionÚ extensionÚfr Ú url_tables úVH:\Change_password\venv_build\Lib\site-packages\pandas/tests/io/parser/test_network.pyÚtest_compressed_urlsr* s± ð 5Ò Ü ÐKÔLà(Ð)9Ñ:IÜ htX v¨~À Ñ/IÓJÈDÓ Qð 3ÐUVØ× Ñ ¨¯©«Ð Ô2÷3ð ..?Ñ
|
*¨YÑ
|
6Cà zÒØ Ðä $Ð4DÈVÔTIÜ×Ñ) ^Õ4÷3ð 3ús ¸!B  B)c óð t |dddd« d« 5 }| j |j « ¬« t | j dd¬ « }ddd« j
|
d
|
d k( sJ y# 1 sw Y xY w) zN
|
read_csv should honor the requested encoding for URLs.
|
|
GH 10424
|
r r r zunicode_series.csvr r zlatin-1N)ÚencodingÚheader)é é u$ à köldum klaka (Cold Fever) (1994))r r r r r Úloc)r! r" r' Údfs r) Útest_url_encoding_csvr2 8 sw ô
|
htX vÐ/CÓDÀdÓ Kð GÈqØ× Ñ ¨¯©«Ð Ô2Ü jnn¨yÀÔ F÷Gð 66%=Ð BÒ BÐBÑ B÷Gð Gús 9A,Á,A5c ó* t | dddd« « S )z DataFrame with the tips dataset.r r Úcsvútips.csvr )r" s r) Útips_dfr6 F s ô HT 6¨5°*Ó=Ó >Ð>ó Ú s3_resourcec ó\ e Zd Zd Zd Zd Zd Zd Zd Zd Z d Z
|
d Z d
|
Z d Z d Zej j# d d¬« d « Zej j# d d¬« d « Zej j( d « Zej j( d « Zd Zd Zy)ÚTestS3c óì t j d« dD ]Z \ }}t d|j d|z ||¬« }t |t
|
« sJ |j rJ t j ||« \ y )NÚs3fs©)Ú N)ú.gzÚgzip)ú.bz2Úbz2ús3://ú /tips.csv)r Ústorage_options© r Ú importorskipr ÚnameÚ
|
isinstancer Úemptyr r ©ÚselfÚs3_public_bucket_with_datar6 Ús3soÚextÚcompr1 s r) Útest_parse_public_s3_bucketz"TestS3.test_parse_public_s3_bucketP s| ô ×ÑFÔ#ØGò /ICÜØÐ2×7Ñ7Ð8¸ ÐBÀSÑHØ Ø $ôBô
|
b¤)Ô,Ð ,Ð,ØxxÐ <Ü × !Ñ ! " gÕ .ñ /r7 c óÐ t j d« t d|j d|¬« }t |t
|
« sJ |j rJ t j ||« y )Nr< rC rD ©rE rF )rL Ús3_private_bucket_with_datar6 rN r1 s r) Ú test_parse_private_s3_bucketz#TestS3.test_parse_private_s3_bucket^ s_ ä×ÑFÔ#Ü ØÐ/×4Ñ4Ð5°YÐ ?ÐQUô
|
ô "iÔ(Ð(Ð(Ø88Ð|Ü
|
× Ñ b 'Õ*r7 c ó t d|j dd|¬« }t |t « sJ |j rJ t j |j d d |« y )Nzs3n://rD é
|
©ÚnrowsrE ©r rH rI r rJ r r Úiloc©rL rM r6 rN r1 s r) Ú test_parse_public_s3n_bucketz#TestS3.test_parse_public_s3n_bucketh ó_ ä ØÐ/×4Ñ4Ð5°YÐ ?ØØ ô
|
ô
|
"iÔ(Ð(Ð(Ø88Ð|Ü
|
× Ñ gll¨3¨BÐ /°Õ4r7 c ó t d|j dd|¬« }t |t « sJ |j rJ t j |j d d |« y )Nzs3a://rD rW rX rZ r\ s r) Ú test_parse_public_s3a_bucketz#TestS3.test_parse_public_s3a_buckets r^ r7 c óÞ dD ]h \ }}t d|j d|z d||¬« }t |t « sJ |j rJ t j |j d d |« j y )Nr= rC rD rW )rY r rE rZ rK s r) Ú!test_parse_public_s3_bucket_nrowsz(TestS3.test_parse_public_s3_bucket_nrows~ s} ð Hò 9ICÜØÐ2×7Ñ7Ð8¸ ÐBÀSÑHØØ Ø $ô Bô b¤)Ô,Ð ,Ð,ØxxÐ <Ü × !Ñ ! '§,¡,¨s°Ð"3°RÕ 8ñ 9r7 c ót d}dD ]¥ \ }}t d|j d|z |||¬« 5 }|j |k( sJ dD ]` }|j « } t | t
|
« sJ | j rJ |j ||z ||dz z }
|
t j |
|
| « b d d d « § y # 1 sw Y ²xY w)Né r= rC rD )Ú chunksizer rE ©r r/ é r/ ©
|
r rH re Ú get_chunkrI r rJ r[ r r © rL rM r6 rN re rO rP Ú df_readerÚi_chunkr1 Útrue_dfs r) Ú#test_parse_public_s3_bucket_chunkedz*TestS3.test_parse_public_s3_bucket_chunked sç ð ØGò 7ICÜØÐ2×7Ñ7Ð8¸ ÐBÀSÑHØ#Ø Ø $ô ð 7ð
|
Ø ×*Ñ*¨iÒ7Ð7Ð7Ø (ò 7Gð #×,Ñ,Ó.BÜ% b¬)Ô4Ð4Ð4Ø !xxÐ'<Ø %llØ! GÑ+¨i¸7ÀQ¹;Ñ.Gð Gô ×)Ñ)¨'°2Õ6ñ 7÷ 7ð 7ñ 7÷ 7ð 7ús «A7B.Â.B7 c óv d}dD ]¦ \ }}t d|j d|z ||d|¬« 5 }|j |k( sJ dD ]` }|j « } t | t
|
« sJ | j rJ |j ||z ||dz z }
|
t j |
|
| « b d d d « ¨ y # 1 sw Y ³xY w) Nrd r= rC rD r )re r r rE rf r/ rh rj s r) Ú*test_parse_public_s3_bucket_chunked_pythonz1TestS3.test_parse_public_s3_bucket_chunked_python¤ sè ð ØGò 7ICÜØÐ2×7Ñ7Ð8¸ ÐBÀSÑHØ#Ø Ø Ø $ô ð 7ð Ø ×*Ñ*¨iÒ7Ð7Ð7Ø (ò 7Gà"×,Ñ,Ó.BÜ% b¬)Ô4Ð4Ð4Ø !xxÐ'<Ø %llØ! GÑ+¨i¸7ÀQ¹;Ñ.Gð Gô ×)Ñ)¨'°2Õ6ñ7÷ 7ð 7ñ 7÷ 7ð 7ús ¬A7B/Â/B8 c óÄ dD ][ \ }}t d|j d|z d||¬« }t |t « sJ |j rJ t j ||« ] y )Nr= rC rD r ©r r rE ©r rH rI r rJ r r rK s r) Ú"test_parse_public_s3_bucket_pythonz)TestS3.test_parse_public_s3_bucket_python¼ sr ð Hò /ICÜØÐ2×7Ñ7Ð8¸ ÐBÀSÑHØ Ø Ø $ô Bô b¤)Ô,Ð ,Ð,ØxxÐ <Ü × !Ñ ! " gÕ .ñ /r7 c ó¾ dD ]X }t d|j d|z dd|¬« }t |t « sJ |j rJ t j ||« Z y )N)r> r? rA rC rD r r
|
rr rs )rL rM r6 rN rO r1 s r) Útest_infer_s3_compressionz TestS3.test_infer_s3_compressionÊ sk Ø&ò /CÜØÐ2×7Ñ7Ð8¸ ÐBÀSÑHØ Ø #Ø $ô Bô b¤)Ô,Ð ,Ð,ØxxÐ <Ü × !Ñ ! " gÕ .ñ /r7 c óà dD ]i \ }}t d|j d|z dd||¬« }t |t « sJ |j rJ t j |j d d |« k y )Nr= rC rD r rW )r rY r rE rZ rK s r) Ú(test_parse_public_s3_bucket_nrows_pythonz/TestS3.test_parse_public_s3_bucket_nrows_pythonÖ s ð Hò
|
9ICÜØÐ2×7Ñ7Ð8¸ ÐBÀSÑHØ ØØ Ø $ô Bô b¤)Ô,Ð ,Ð,ØxxÐ <Ü × !Ñ ! '§,¡,¨s°Ð"3°RÕ 8ñ
|
9r7 c ó d}t j t |¬« 5 t d|¬« d d d « y # 1 sw Y y xY w)Nú#The specified bucket does not exist©Úmatchzs3://nyqpug/asdf.csvrS )r ÚraisesÚOSErrorr )rL rN Úmsgs r) Útest_read_s3_failszTestS3.test_read_s3_failså s9 Ø3Ü ]]7¨#Ô .ñ CÜ Ð+¸TÕ B÷ C÷ Cñ Cús 5µ>c ó d}t j t |¬« 5 t d|j d« d d d « y # 1 sw Y y xY w)Nrz r{ rC z /file.csv)r r} r~ r rH )rL Ús3_private_bucketrN r s r) Útest_read_s3_fails_privatez!TestS3.test_read_s3_fails_privateê sI Ø3ô ]]7¨#Ô .ñ @Ü uÐ .× 3Ñ 3Ð 4°IÐ>Ô ?÷ @÷ @ñ @ús AÁA
|
zGH#39155 s3fs upgradeF)ÚreasonÚstrictc óÂ dd l }t |j j f}t j
|
|d¬« 5 |j d|¬« d d d « y # 1 sw Y y xY w)Nr rz r{ z/s3://an_s3_bucket_data_doesnt_exit/not_real.csvrS )ÚbotocoreÚFileNotFoundErrorÚ
|
exceptionsÚ ClientErrorr r} Úto_csv©rL r6 rN r Úerrors r) Útest_write_s3_csv_failsz TestS3.test_write_s3_csv_failsñ sZ ó ô
|
# H×$7Ñ$7×$CÑ$CÐDä ]]5Ð(MÔ Nñ Ø NNØAÐSWð ô ÷ ÷ ñ ús ¸AÁA c óì t j d« dd l}t |j j
|
f}t j |d¬« 5 |j d|¬« d d d « y # 1 sw Y y xY w)NÚpyarrowr rz r{ z3s3://an_s3_bucket_data_doesnt_exit/not_real.parquetrS )r rG r r r r r} Ú
|
to_parquetr s r) Útest_write_s3_parquet_failsz"TestS3.test_write_s3_parquet_fails sj ô ×ÑIÔ&Ûô
|
# H×$7Ñ$7×$CÑ$CÐDä ]]5Ð(MÔ Nñ Ø × Ñ ØEØ $ð ô ÷ ÷ ñ ús Á A*Á*A3c ó@ |j d« }t |j « d j « « 5 }t |d¬« }d d d « t t « sJ |j rJ t |« }t j ||« y # 1 sw Y KxY w)Nr5 ÚBodyÚutf8)r, )
|
ÚObjectr Úgetr r rI r rJ r r )rL rM Ú tips_fileÚ s3_objectÚbufferÚresultÚexpecteds r) Ú$test_read_csv_handles_boto_s3_objectz+TestS3.test_read_csv_handles_boto_s3_object s ð /×5Ñ5°jÓA ä Y]]_ VÑ,×1Ñ1Ó3Ó 4ð 7¸Ü f¨vÔ6F÷ 7ä&¤)Ô,Ð,Ð,Ø<<Ð Ð äIÓ&Ü
|
× Ñ f hÕ/÷ 7ð 7ús ¼BÂB c óh t t j d« t d« ¬« }t |j « j d« « 5 }|j d|¬« |j d}t j d| d « }|j t j d
|
¬ « 5 t d | d |¬« |j D ]: }t j ||« x} s t# | j% d« « dk r:J d d d « d d d « y # 1 sw Y xY w# 1 sw Y y xY w)N)i é Úabcd)Úcolumnszutf-8zlarge-file.csv)ÚKeyr z/large-file.csvz^Fetch: z, 0-(?P<stop>\d+)$r< )ÚloggerrC rd rX Ústopi z )r ÚnpÚzerosÚlistr r ÚencodeÚ
|
put_objectrH ÚreÚcompileÚat_levelÚloggingÚDEBUGr Úmessagesr| ÚintÚgroup)
|
rL Ús3_public_bucketÚcaplogrN r1 ÚbufÚuriÚmatch_reÚlogr| s
|
r) Ú test_read_csv_chunked_downloadz%TestS3.test_read_csv_chunked_download# s# ô rxx Ó,´d¸6³lÔ CÜ RYY[×'Ñ'¨Ó0Ó 1ð B°SØ × 'Ñ 'Ð,<À3Ð 'Ô GØ%×*Ñ*Ð+¨?Ð;CÜzz X¨c¨UÐ2DÐ"EÓFHØ ¤§ ¡ °v Ó>ñ BÜØC5MØØ$(õð
|
"??ò BCÜ "§¡¨°3Ó 7Ð7uÑ7ä " 5§;¡;¨vÓ#6Ó 7¸'Ó AÐAÐ AñB÷ B÷ Bð B÷ Bð Bú÷ Bð Bús1 ÁA D(Â/9D Ã) D ÄD Ä D(Ä D% Ä!D(Ä(D1c óf t d|j d|¬« }t j ||« y )NrC z /tips#1.csvrS )r rH r r )rL rM r6 rN r s r) Ú test_read_s3_with_hash_in_keyz$TestS3.test_read_s3_with_hash_in_key6 s5 äØÐ.×3Ñ3Ð4°KÐ @ÐRVô
|
ô × Ñ g vÕ.r7 c ó¦ t j d« t |« }t d|j d|¬« }t j
|
||« y )Nr rC z/simple_dataset.featherrS )r rG r rH r r )rL rM Ú feather_filerN r Úress r) Ú test_read_feather_s3_file_pathz%TestS3.test_read_feather_s3_file_path= sP ô ×ÑIÔ&Ü Ó-ÜØÐ.×3Ñ3Ð4Ð4KÐ LØ ô
|
ô × Ñ h¨Õ,r7 N)Ú__name__Ú
|
__module__Ú __qualname__rQ rU r] r` rb rn rp rt rv rx r r r ÚmarkÚxfailr r Ú
|
single_cpur r¸ rº r¾ © r7 r) r: r: L sÜ ò /ò +ò 5ò 5ò 9ò 7ò07ò0 /ò
|
/ò 9ò Cò
|
@ð [[×ÑÐ 5¸eÐÓDñ ó Eð ð [[×ÑÐ 5¸eÐÓDñó Eðð" [[×Ññ 0ó ð 0ð [[×ÑñBó ðBò$/ó
|
-r7 r: )"Ú__doc__r r r rª Únumpyr¥ r Ú pandas.util._test_decoratorsÚutilÚ_test_decoratorsÚtdÚpandasr Úpandas._testingÚ_testingr Úpandas.io.feather_formatr Úpandas.io.parsersr r ÚfilterwarningsÚ
|
pytestmarkÚnetworkrÄ Ú parametrizer* r2 Úfixturer6 Ú usefixturesÚskip_if_not_us_localer: rÅ r7 r) ú<module>rØ sI ðñõ Û Û ã Û ç )Ð )å Ý å 1Ý &à [[× 'Ñ 'ØCó
|
ð
|
×ÑØ×ÑØ×Ñ *¨gÐ!6Ó7Ø×Ñ H¨c ?Ó3ñ5ó 4ó 8ó ó ð5ð6 ×ÑØ×Ññ Có ó ð Cð ñ?ó ð?ð
|
×ÑØ×Ñ Ó'Ø×ÑÓ÷x-ð x-ó ó (ó ñx-r7
|
