Loading...

verticapy.read_csv#

verticapy.read_csv(path: str, schema: str | None = None, table_name: str | None = None, sep: str | None = None, header: bool = True, header_names: list | None = None, dtype: dict | None = None, na_rep: str | None = None, quotechar: str = '"', escape: str = '\x17', record_terminator: str = '\n', trim: bool = True, omit_empty_keys: bool = False, reject_on_duplicate: bool = False, reject_on_empty_key: bool = False, reject_on_materialized_type_error: bool = False, parse_nrows: int = -1, insert: bool = False, temporary_table: bool = False, temporary_local_table: bool = True, gen_tmp_table_name: bool = True, ingest_local: bool = True, genSQL: bool = False, materialize: bool = True) vDataFrame#

Ingests a CSV file using flex tables.

Parameters#

path: str

Absolute path where the CSV file is located.

schema: str, optional

Schema where the CSV file will be ingested.

table_name: str, optional

The final relation/table name. If unspecified, the name is set to the name of the file or parent directory.

sep: str, optional

Column separator.

header: bool, optional

If set to False, the parameter header_names is used to name the different columns.

header_names: list, optional

list of the column names.

dtype: dict, optional

dictionary of the user types. Providing a dictionary can increase ingestion speed and precision; instead of parsing the file to guess the different types, VerticaPy will use the input types.

na_rep: str, optional

Missing values representation.

quotechar: str, optional

Char that encloses the str values.

escape: str, optional

Separator between each record.

record_terminator: str, optional

A single-character value used to specify the end of a record.

trim: bool, optional

boolean, specifies whether to trim white space from header names and key values.

omit_empty_keys: bool, optional

boolean, specifies how the parser handles header keys without values. If True, keys with an empty value in the header row are not loaded.

reject_on_duplicate: bool, optional

boolean, specifies whether to ignore duplicate records (False), or to reject duplicates (True). In either case, the load continues.

reject_on_empty_key: bool, optional

boolean, specifies whether to reject any row containing a key without a value.

reject_on_materialized_type_error: bool, optional

boolean, specifies whether to reject any materialized column value that the parser cannot coerce into a compatible data type.

parse_nrows: int, optional

If this parameter is greater than zero, a new file of parse_nrows rows is created and ingested to identify the data types. It is then dropped and the entire file is ingested. The data types identification will be less precise but this parameter can make the process faster if the file is large.

insert: bool, optional

If set to True, the data is ingested into the specified input relation. Be sure that your file has a header corresponding to the name of the relation columns, otherwise ingestion will fail.

temporary_table: bool, optional

If set to True, a temporary table will be created.

temporary_local_table: bool, optional

If set to True, a temporary local table will be created. The parameter schema must be empty, otherwise this parameter is ignored.

gen_tmp_table_name: bool, optional

Sets the name of the temporary table. This parameter is only used when the parameter temporary_local_table is set to True and if the parameters table_name and schema are unspecified.

ingest_local: bool, optional

If set to True, the file is ingested from the local machine.

genSQL: bool, optional

If set to True, the SQL code for creating the final table is generated but not executed. This is a good way to change the final relation types or to customize the data ingestion.

materialize: bool, optional

If set to True, the flex table is materialized into a table. Otherwise, it will remain a flex table. Flex tables simplify the data ingestion but have worse performace compared to regular tables.

Returns#

vDataFrame

The vDataFrame of the relation.

Examples#

In this example, we will first create a CSV file using vDataFrame.to_csv() and ingest it into Vertica database.

We import verticapy:

import verticapy as vp

Hint

By assigning an alias to verticapy, we mitigate the risk of code collisions with other libraries. This precaution is necessary because verticapy uses commonly known function names like “average” and “median”, which can potentially lead to naming conflicts. The use of an alias ensures that the functions from verticapy are used as intended without interfering with functions from other libraries.

We will use the Titanic dataset.

import verticapy.datasets as vpd

data = vpd.load_titanic()
123
pclass
Integer
123
survived
Integer
Abc
Varchar(164)
Abc
sex
Varchar(20)
123
age
Numeric(8)
123
sibsp
Integer
123
parch
Integer
Abc
ticket
Varchar(36)
123
fare
Numeric(12)
Abc
cabin
Varchar(30)
Abc
embarked
Varchar(20)
Abc
boat
Varchar(100)
123
body
Integer
Abc
home.dest
Varchar(100)
110female2.012113781151.55C22 C26S[null][null]Montreal, PQ / Chesterville, ON
210male30.012113781151.55C22 C26S[null]135Montreal, PQ / Chesterville, ON
310female25.012113781151.55C22 C26S[null][null]Montreal, PQ / Chesterville, ON
410male39.0001120500.0A36S[null][null]Belfast, NI
510male71.000PC 1760949.5042[null]C[null]22Montevideo, Uruguay
610male47.010PC 17757227.525C62 C64C[null]124New York, NY
710male[null]00PC 1731825.925[null]S[null][null]New York, NY
810male24.001PC 17558247.5208B58 B60C[null][null]Montreal, PQ
910male36.0001305075.2417C6CA[null]Winnipeg, MN
1010male25.0001390526.0[null]C[null]148San Francisco, CA
1110male45.00011378435.5TS[null][null]Trenton, NJ
1210male42.00011048926.55D22S[null][null]London / Winnipeg, MB
1310male41.00011305430.5A21S[null][null]Pomeroy, WA
1410male48.000PC 1759150.4958B10C[null]208Omaha, NE
1510male[null]0011237939.6[null]C[null][null]Philadelphia, PA
1610male45.00011305026.55B38S[null][null]Washington, DC
1710male[null]0011379831.0[null]S[null][null][null]
1810male33.0006955.0B51 B53 B55S[null][null]New York, NY
1910male28.00011305947.1[null]S[null][null]Montevideo, Uruguay
2010male17.00011305947.1[null]S[null][null]Montevideo, Uruguay
2110male49.0001992426.0[null]S[null][null]Ascot, Berkshire / Rochester, NY
2210male36.0101987778.85C46S[null]172Little Onn Hall, Staffs
2310male46.010W.E.P. 573461.175E31S[null][null]Amenia, ND
2410male[null]001120510.0[null]S[null][null]Liverpool, England / Belfast
2510male27.01013508136.7792C89C[null][null]Los Angeles, CA
2610male[null]0011046552.0A14S[null][null]Stoughton, MA
2710male47.000572725.5875E58S[null][null]Victoria, BC
2810male37.011PC 1775683.1583E52C[null][null]Lakewood, NJ
2910male[null]0011379126.55[null]S[null][null]Roachdale, IN
3010male70.011WE/P 573571.0B22S[null]269Milwaukee, WI
3110male39.010PC 1759971.2833C85C[null][null]New York, NY
3210male31.010F.C. 1275052.0B71S[null][null]Montreal, PQ
3310male50.010PC 17761106.425C86C[null]62Deephaven, MN / Cedar Rapids, IA
3410male39.000PC 1758029.7A18C[null]133Philadelphia, PA
3510female36.000PC 1753131.6792A29C[null][null]New York, NY
3610male[null]00PC 17483221.7792C95S[null][null][null]
3710male30.00011305127.75C111C[null][null]New York, NY
3810male19.03219950263.0C23 C25 C27S[null][null]Winnipeg, MB
3910male64.01419950263.0C23 C25 C27S[null][null]Winnipeg, MB
4010male[null]0011377826.55D34S[null][null]Westcliff-on-Sea, Essex
4110male[null]001120580.0B102S[null][null][null]
4210male37.01011380353.1C123S[null][null]Scituate, MA
4310male47.00011132038.5E63S[null]275St Anne's-on-Sea, Lancashire
4410male24.000PC 1759379.2B86C[null][null][null]
4510male71.000PC 1775434.6542A5C[null][null]New York, NY
4610male38.001PC 17582153.4625C91S[null]147Winnipeg, MB
4710male46.000PC 1759379.2B82 B84C[null][null]New York, NY
4810male[null]0011379642.4[null]S[null][null][null]
4910male45.0103697383.475C83S[null][null]New York, NY
5010male40.0001120590.0B94S[null]110[null]
5110male55.0111274993.5B69S[null]307Montreal, PQ
5210male42.00011303842.5B11S[null][null]London / Middlesex
5310male[null]001746351.8625E46S[null][null]Brighton, MA
5410male55.00068050.0C39S[null][null]London / Birmingham
5510male42.01011378952.0[null]S[null]38New York, NY
5610male[null]00PC 1760030.6958[null]C14[null]New York, NY
5710female50.000PC 1759528.7125C49C[null][null]Paris, France New York, NY
5810male46.00069426.0[null]S[null]80Bennington, VT
5910male50.00011304426.0E60S[null][null]London
6010male32.500113503211.5C132C[null]45[null]
6110male58.0001177129.7B37C[null]258Buffalo, NY
6210male41.0101746451.8625D21S[null][null]Southington / Noank, CT
6310male[null]0011302826.55C124S[null][null]Portland, OR
6410male[null]00PC 1761227.7208[null]C[null][null]Chicago, IL
6510male29.00011350130.0D6S[null]126Springfield, MA
6610male30.00011380145.5[null]S[null][null]London / New York, NY
6710male30.00011046926.0C106S[null][null]Brockton, MA
6810male19.01011377353.1D30S[null][null]New York, NY
6910male46.0001305075.2417C6C[null]292Vancouver, BC
7010male54.0001746351.8625E46S[null]175Dorchester, MA
7110male28.010PC 1760482.1708[null]C[null][null]New York, NY
7210male65.0001350926.55E38S[null]249East Bridgewater, MA
7310male44.0201992890.0C78Q[null]230Fond du Lac, WI
7410male55.00011378730.5C30S[null][null]Montreal, PQ
7510male47.00011379642.4[null]S[null][null]Washington, DC
7610male37.001PC 1759629.7C118C[null][null]Brooklyn, NY
7710male58.00235273113.275D48C[null]122Lexington, MA
7810male64.00069326.0[null]S[null]263Isle of Wight, England
7910male65.00111350961.9792B30C[null]234Providence, RI
8010male28.500PC 1756227.7208D43C[null]189?Havana, Cuba
8110male[null]001120520.0[null]S[null][null]Belfast
8210male45.50011304328.5C124S[null]166Surbiton Hill, Surrey
8310male23.0001274993.5B24S[null][null]Montreal, PQ
8410male29.01011377666.6C2S[null][null]Isleworth, England
8510male18.010PC 17758108.9C65C[null][null]Madrid, Spain
8610male47.00011046552.0C110S[null]207Worcester, MA
8710male38.000199720.0[null]S[null][null]Rotterdam, Netherlands
8810male22.000PC 17760135.6333[null]C[null]232[null]
8910male[null]00PC 17757227.525[null]C[null][null][null]
9010male31.000PC 1759050.4958A24S[null][null]Trenton, NJ
9110male[null]0011376750.0A32S[null][null]Seattle, WA
9210male36.0001304940.125A10C[null][null]Winnipeg, MB
9310male55.010PC 1760359.4[null]C[null][null]New York, NY
9410male33.00011379026.55[null]S[null]109London
9510male61.013PC 17608262.375B57 B59 B63 B66C[null][null]Haverford, PA / Cooperstown, NY
9610male50.0101350755.9E44S[null][null]Duluth, MN
9710male56.00011379226.55[null]S[null][null]New York, NY
9810male56.0001776430.6958A7C[null][null]St James, Long Island, NY
9910male24.0101369560.0C31S[null][null]Huntington, WV
10010male[null]0011305626.0A19S[null][null]Streatham, Surrey
Rows: 1-100 | Columns: 14

Note

VerticaPy offers a wide range of sample datasets that are ideal for training and testing purposes. You can explore the full list of available datasets in the Datasets, which provides detailed information on each dataset and how to use them effectively. These datasets are invaluable resources for honing your data analysis and machine learning skills within the VerticaPy environment.

Let’s convert the vDataFrame to a CSV.

data[0:20].to_csv(
    path = "titanic_subset.csv",
)

Our CSV file is ready to be ingested in database.

Let’s generate, the SQL needed to create the Table.

from verticapy.core.parsers.csv import read_csv

read_csv(
    path = "titanic_subset.csv",
    table_name = "titanic_subset",
    schema = "public",
    quotechar = '"',
    sep = ",",
    na_rep = "",
    genSQL = True,
)

Out[4]: 
['CREATE TABLE "public"."titanic_subset"("pclass" Integer, "survived" Integer, "name" Varchar(94), "sex" Varchar(20), "age" Numeric(8,4), "sibsp" Integer, "parch" Integer, "ticket" Varchar(20), "fare" Numeric(11,6), "cabin" Varchar(22), "embarked" Varchar(20), "boat" Varchar(20), "body" Integer, "home.dest" Varchar(62))',
 'COPY "public"."titanic_subset"("pclass", "survived", "name", "sex", "age", "sibsp", "parch", "ticket", "fare", "cabin", "embarked", "boat", "body", "home.dest") FROM LOCAL \'titanic_subset.csv\' UNCOMPRESSED DELIMITER \',\' NULL \'\' ENCLOSED BY \'"\' RECORD TERMINATOR E\'\\n\' ESCAPE AS \'\x17\' SKIP 1']

Note

When genSQL flag is set to True, the SQL code for creating the final table is generated but not executed. This is a good way to change the final relation types or to customize the data ingestion.

Now, we will ingest the CSV file into the Vertica database.

read_csv(
    path = "titanic_subset.csv",
    table_name = "titanic_subset",
    schema = "public",
    quotechar = '"',
    sep = ",",
    na_rep = "",
)
123
pclass
Integer
123
survived
Integer
Abc
Varchar(94)
Abc
sex
Varchar(20)
123
age
Numeric(10)
123
sibsp
Integer
123
parch
Integer
Abc
ticket
Varchar(20)
123
fare
Numeric(13)
Abc
cabin
Varchar(22)
Abc
embarked
Varchar(20)
Abc
boat
Varchar(20)
123
body
Integer
Abc
home.dest
Varchar(62)
110female2.012113781151.55C22 C26S[null][null]Montreal, PQ / Chesterville, ON
210male30.012113781151.55C22 C26S[null]135Montreal, PQ / Chesterville, ON
310female25.012113781151.55C22 C26S[null][null]Montreal, PQ / Chesterville, ON
410male39.0001120500.0A36S[null][null]Belfast, NI
510male71.000PC 1760949.5042[null]C[null]22Montevideo, Uruguay
610male47.010PC 17757227.525C62 C64C[null]124New York, NY
710male[null]00PC 1731825.925[null]S[null][null]New York, NY
810male24.001PC 17558247.5208B58 B60C[null][null]Montreal, PQ
910male36.0001305075.2417C6CA[null]Winnipeg, MN
1010male25.0001390526.0[null]C[null]148San Francisco, CA
1110male45.00011378435.5TS[null][null]Trenton, NJ
1210male42.00011048926.55D22S[null][null]London / Winnipeg, MB
1310male41.00011305430.5A21S[null][null]Pomeroy, WA
1410male48.000PC 1759150.4958B10C[null]208Omaha, NE
1510male[null]0011237939.6[null]C[null][null]Philadelphia, PA
1610male45.00011305026.55B38S[null][null]Washington, DC
1710male[null]0011379831.0[null]S[null][null][null]
1810male33.0006955.0B51 B53 B55S[null][null]New York, NY
1910male28.00011305947.1[null]S[null][null]Montevideo, Uruguay
2010male17.00011305947.1[null]S[null][null]Montevideo, Uruguay
Rows: 1-20 | Columns: 14

Important

A limited number of rows, determined by the parse_nrows parameter, is ingested. If your dataset is large and you want to ingest the entire dataset, increase its value.

Let’s specify data types using dtype parameter.

read_csv(
    path = "titanic_subset.csv",
    table_name = "titanic_sub_dtypes",
    schema = "public",
    quotechar = '"',
    sep = ",",
    na_rep = "",
    dtype = {
        "pclass": "Integer",
        "survived": "Integer",
        "name": "Varchar(164)",
        "sex": "Varchar(20)",
        "age": "Numeric(6,3)",
        "sibsp": "Integer",
        "parch": "Integer",
        "ticket": "Varchar(36)",
        "fare": "Numeric(10,5)",
        "cabin": "Varchar(30)",
        "embarked": "Varchar(20)",
        "boat": "Varchar(100)",
        "body": "Integer",
        "home.dest": "Varchar(100)",
    },
)
123
pclass
Integer
123
survived
Integer
Abc
Varchar(164)
Abc
sex
Varchar(20)
123
age
Numeric(8)
123
sibsp
Integer
123
parch
Integer
Abc
ticket
Varchar(36)
123
fare
Numeric(12)
Abc
cabin
Varchar(30)
Abc
embarked
Varchar(20)
Abc
boat
Varchar(100)
123
body
Integer
Abc
home.dest
Varchar(100)
110female2.012113781151.55C22 C26S[null][null]Montreal, PQ / Chesterville, ON
210male30.012113781151.55C22 C26S[null]135Montreal, PQ / Chesterville, ON
310female25.012113781151.55C22 C26S[null][null]Montreal, PQ / Chesterville, ON
410male39.0001120500.0A36S[null][null]Belfast, NI
510male71.000PC 1760949.5042[null]C[null]22Montevideo, Uruguay
610male47.010PC 17757227.525C62 C64C[null]124New York, NY
710male[null]00PC 1731825.925[null]S[null][null]New York, NY
810male24.001PC 17558247.5208B58 B60C[null][null]Montreal, PQ
910male36.0001305075.2417C6CA[null]Winnipeg, MN
1010male25.0001390526.0[null]C[null]148San Francisco, CA
1110male45.00011378435.5TS[null][null]Trenton, NJ
1210male42.00011048926.55D22S[null][null]London / Winnipeg, MB
1310male41.00011305430.5A21S[null][null]Pomeroy, WA
1410male48.000PC 1759150.4958B10C[null]208Omaha, NE
1510male[null]0011237939.6[null]C[null][null]Philadelphia, PA
1610male45.00011305026.55B38S[null][null]Washington, DC
1710male[null]0011379831.0[null]S[null][null][null]
1810male33.0006955.0B51 B53 B55S[null][null]New York, NY
1910male28.00011305947.1[null]S[null][null]Montevideo, Uruguay
2010male17.00011305947.1[null]S[null][null]Montevideo, Uruguay
Rows: 1-20 | Columns: 14

Note

You can ingest multiple CSV files into the Vertica database by using the following syntax.

read_csv(
    path = "*.csv",
    table_name = "titanic_multi_files",
    schema = "public",
    quotechar = '"',
    sep = ",",
    na_rep = "",
)

Note

The read_csv() function offers various additional parameters and options. Check the documentation to explore its capabilities, such as the ability to automatically guess the separator or ingest a specific number of rows.

See also

read_json() : Ingests a JSON file into the Vertica DB.