403Webshell
Server IP : 209.209.40.120  /  Your IP : 216.73.217.112
Web Server : Microsoft-IIS/10.0
System : Windows NT NEWWWW 10.0 build 17763 (Windows Server 2019) i586
User : NEWWWW$ ( 0)
PHP Version : 8.3.30
Disable Function : NONE
MySQL : OFF  |  cURL : ON  |  WGET : OFF  |  Perl : OFF  |  Python : OFF  |  Sudo : OFF  |  Pkexec : OFF
Directory :  C:/Python312/Lib/site-packages/pandas/tests/io/__pycache__/

Upload File :
current_dir [ Writeable ] document_root [ Writeable ]

 

Command :


[ Back ]     

Current File : C:/Python312/Lib/site-packages/pandas/tests/io/__pycache__/test_gcs.cpython-312.pyc
�

0	�g�����ddlmZddlZddlZddlZddlZddlZddlZddl	m
Z
ddlmZm
Z
mZmZmZmZmZddlmZddlmZej2j5d�Zej8d��Zej2j<ej2j?dgd	��d
���Z de!de!d
e"fd�Z#ej2j?dddg�d��Z$d�Z%ejLd�d��Z'y)�)�BytesION)�pa_version_under17p0)�	DataFrame�Index�
date_range�read_csv�
read_excel�	read_json�read_parquet)�_test_decoratorsz=ignore:Passing a BlockManager to DataFrame:DeprecationWarningc����tjd�tjd�}t��d��_G�fd�d|j�}|jd|d���S)	z"Emulate GCS using a binary buffer.�gcsfs�fsspecc��y)NT�r��:C:\Python312\Lib\site-packages\pandas/tests/io/test_gcs.py�<lambda>zgcs_buffer.<locals>.<lambda>$s�rc�(��eZdZe�fd��Zd�Zy)�%gcs_buffer.<locals>.MockGCSFileSystemc�*���jd��S)Nr)�seek)�args�kwargs�
gcs_buffers  �r�openz*gcs_buffer.<locals>.MockGCSFileSystem.open's����O�O�A���rc��|dd�gS)N�file)�name�typer)�self�pathrs   r�lsz(gcs_buffer.<locals>.MockGCSFileSystem.ls,s��!�6�2�3�3rN)�__name__�
__module__�__qualname__�staticmethodrr#)rs�r�MockGCSFileSystemr&s���	�	�
�	�	4rr(�gsT)�clobber)�pytest�importorskipr�close�AbstractFileSystem�register_implementation)rr(rs  @rrrsb������� �
�
 �
 ��
*�F���J�#�J��4�F�5�5�4��"�"�4�):�D�"�I��r�format)�csv�json�parquet�excel�markdownc	����tddgdtjgddgtdd��d	��}d
|��}|dk(r$|j	|d�
�t|dgd��}�ne|dk(r$d}|j
|�t|dgd��}�n<|dk(r!|j|�t|dg��}�n|dk(r�tjd�tjd��G�fd�d�j�}|jtjjt t"d���|j%�5}	|	j'�d|�|j)|�t+|�}ddd�|j-�}
|
j.dk(s/J�|dk(r(tjd �|j1|�|}t3j4|�y#1swY�nxYw)!zE
    Test that many to/read functions support GCS.

    GH 33987
    ���@�t�s�
2018-06-18���periods��int�float�str�dtzgs://test/test.r1T)�indexrDr)�parse_dates�	index_colr4zgs://test/test.xlsxr2)�
convert_datesr3�pyarrowz
pyarrow.fsc�"��eZdZe�fd��Zy)�(test_to_read_gcs.<locals>.MockFileSystemc���td�tj|jdd��j	�j�}�j
|�S)NzUsing pyarrow filesystemzgs://�)�print�pathlib�Path�replace�absolute�as_uri�LocalFileSystem)r"�to_local�pa_fss  �r�from_uriz1test_to_read_gcs.<locals>.MockFileSystem.from_uriZsH����0�1�"�<�<����W�b�(A�B�K�K�M�T�T�V���,�,�X�6�6rN)r$r%r&r'rW)rVs�r�MockFileSystemrKYs���
�
7��
7rrXz&pyarrow 17 broke the mocked filesystem)�raises�reason�
FileSystemNz2Using pyarrow filesystem
Using pyarrow filesystem
r5�tabulate)r�np�nanr�to_csvr�to_excelr	�to_jsonr
r+r,r[�applymarker�mark�xfailr�	TypeError�context�setattr�
to_parquetr�
readouterr�out�to_markdown�tm�assert_frame_equal)rr0�monkeypatch�capsys�request�df1r"�df2rX�m�capturedrVs           @r�test_to_read_gcsru7s������q�6��2�6�6�]���:��\�1�5�		
��C��V�H�%�D�
����
�
�4�t�
�$��t�$��1�=��	�7�	�$�����T����D�6�Q�?��	�6�	����D����T�F�3��	�9�	����I�&��#�#�L�1��	7�U�-�-�	7�	����K�K���(�(� �?�
�
�	
��
 �
 �
"�	%�a�
�I�I�e�\�>�:��N�N�4� ��t�$�C�	%��$�$�&���|�|�U�U�U�U�	�:�	����J�'�����������#�s�#�	%�	%�s�>0G�G$�result�expected�compressionc�l�|dk(r�tjt|��5}tjt|��5}t|j	�|j	��D] \}}|j
|j
k(r� J�	ddd�ddd�y|dk(r�t
jt|���5}t
jt|���5}t|j�|j��D][\}	}
|j|	�}|j|
�}|du|duk(sJ�|��6|��9|j�|j�k(r�[J�	ddd�ddd�y||k(sJ�y#1swY��xYw#1swYyxYw#1swY�2xYw#1swYyxYw)a
    For zip compression, only compare the CRC-32 checksum of the file contents
    to avoid checking the time-dependent last-modified timestamp which
    in some CI builds is off-by-one

    See https://en.wikipedia.org/wiki/ZIP_(file_format)#File_headers
    �zipN�tar)�fileobj)�zipfile�ZipFilerrz�infolist�CRC�tarfiler�
getmembers�extractfile�read)
rvrwrx�exp�res�res_info�exp_info�tar_exp�tar_res�tar_res_info�tar_exp_info�actual_file�
expected_files
             r�assert_equal_zip_safer�us����e��
�_�_�W�V�_�
-�	4��g�o�o��H��7
�	4�
�&)�#�,�,�.�#�,�,�.�&I�
4�"��(��|�|�x�|�|�3�3�3�
4�	4�	4�	4�

��	�
�\�\�'�&�/�
2�
	F�g�w�|�|��H�%�@
�
	F�
�.1��"�"�$�g�&8�&8�&:�/�
F�*��l�&�1�1�,�?�� '� 3� 3�L� A�
�#�t�+��$�1F�G�G�G��*�}�/H�&�+�+�-��1C�1C�1E�E�E�E�
F�
	F�
	F�
	F���!�!�!�%	4�	4��	4�	4��
	F�
	F��
	F�
	F�sa�F�AF�F�F� F*�%AF�F�!F�)F�-F*�F	�F�F�F'	�#F*�*F3�encoding�utf-8�cp1251c��tdtjd�jd�zt	td�t��t	td�D�cgc]}d|����	c}t����}d	|i}|d
k(rd|d<t�}|j|||d
��d}|j|||��|j�}	|j�}
t|	|
|�t|d||��}tj||�||}d|d	<|d|��z
}|j|||��|j�}	|j�}
t|	|
|�t|dd|��}tj||�ycc}w)z�
    Compression and encoding should with GCS.

    GH 35677 (to_csv, compression), GH 26124 (to_csv, encoding), and
    GH 32392 (read_csv, encoding)
    g�������?�x)���ABCD)�dtyper�zi-)�columnsrE�method�gzipr7�mtime�wb)rxr��mode�gs://test/test.csv)rxr�r)rGrxr��infer�.N)rr]�arange�reshaper�list�object�rangerr_�getvaluer�rrlrm)
r�compression_onlyr��compression_to_extension�i�dfrx�buffer�path_gcsr�rw�read_df�file_exts
             r�$test_to_csv_compression_encoding_gcsr��s|��
��b�i�i��n�$�$�W�-�-��d�6�l�&�1��u�R�y�1�!�r�!��X�1��@�
�B��-�.�K��6�!� ��G��
�Y�F��I�I�f�+��t�I�L�$�H��I�I�h�K�(�I�C�
�
�
�
�C���� �H��#�x�)9�:���A�+;�h��G����"�g�&�(�(8�9�H�#�K����!�H�:���H��I�I�h�K�(�I�C�
�
�
�
�C���� �H��#�x�)9�:��x�1�'�H�U�G����"�g�&��C2s�Fc	�,��tjd�tjd�ddlm}t	ddgdt
jgdd	gtd
d��d
��}G�fd�d|�}|jd|�|jdddd��y)zCRegression test for writing to a not-yet-existent GCS Parquet file.�fastparquetrr)r.r7r8r9r:r;r<r=r>r@c���eZdZd�fd�	Zy)�7test_to_parquet_gcs_new_file.<locals>.MockGCSFileSystemc�p��d|vrt�ttjj	�d�|d��S)N�wztest.parquetr�)r�)�FileNotFoundErrorr�osr"�join)r!r"r�r�tmpdirs    �rrz<test_to_parquet_gcs_new_file.<locals>.MockGCSFileSystem.open�s.����$��'�'�������V�^�<�d�W�U�UrN)�r)r$r%r&r)r�s�rr(r��s	���	Vrr(zgcsfs.GCSFileSystemr�TN)rE�enginerx)
r+r,rr.rr]r^rrgrh)rnr�r.rqr(s `   r�test_to_parquet_gcs_new_filer��s����
���
�&�
���� �)�
��q�6��2�6�6�]���:��\�1�5�		
��C�V�.�V����-�/@�A��N�N��D��D��rrc�v�tjt�5td�ddd�y#1swYyxYw)Nr�)rl�external_error_raised�ImportErrorrrrr�test_gcs_not_present_exceptionr��s.��	�	!�	!�+�	.�'��%�&�'�'�'�s�/�8)(�iorr�rOr�r}�numpyr]r+�pandas.compat.pyarrowr�pandasrrrrr	r
r�pandas._testing�_testingrl�pandas.utilr�tdrc�filterwarnings�
pytestmark�fixturer�
single_cpu�parametrizeru�bytesrCr�r�r��skip_if_installedr�rrr�<module>r�s���	�����
�6�����.�
�[�[�
'�
'�C��
�
������2�����������#R�S�9$�T��9$�x"�%�"�5�"�s�"�>������g�x�%8�9�-'�:�-'�`�8����g��'��'r

Youez - 2016 - github.com/yon3zu
LinuXploit