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 | None = '\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
Varchar(100)
110male71.000PC 1760949.5042[null]C[null]22
210male45.00011378435.5TS[null][null]
310male[null]0011379831.0[null]S[null][null]
410male17.00011305947.1[null]S[null][null]
510male27.01013508136.7792C89C[null][null]
610male37.011PC 1775683.1583E52C[null][null]
710male31.010F.C. 1275052.0B71S[null][null]
810male50.010PC 17761106.425C86C[null]62
910female36.000PC 1753131.6792A29C[null][null]
1010male37.01011380353.1C123S[null][null]
1110male24.000PC 1759379.2B86C[null][null]
1210male45.0103697383.475C83S[null][null]
1310male40.0001120590.0B94S[null]110
1410male42.00011303842.5B11S[null][null]
1510male[null]001746351.8625E46S[null][null]
1610male42.01011378952.0[null]S[null]38
1710male[null]00PC 1760030.6958[null]C14[null]
1810male29.00011350130.0D6S[null]126
1910male46.0001305075.2417C6C[null]292
2010male54.0001746351.8625E46S[null]175
2110male47.00011379642.4[null]S[null][null]
2210male58.00235273113.275D48C[null]122
2310male45.50011304328.5C124S[null]166
2410male29.01011377666.6C2S[null][null]
2510male47.00011046552.0C110S[null]207
2610male38.000199720.0[null]S[null][null]
2710male22.000PC 17760135.6333[null]C[null]232
2810male31.000PC 1759050.4958A24S[null][null]
2910male50.0101350755.9E44S[null][null]
3010male56.0001776430.6958A7C[null][null]
3110male57.010PC 17569146.5208B78C[null][null]
3210female63.010PC 17483221.7792C55 C57S[null][null]
3310male61.0003696332.3208D50S[null]46
3410male21.0013528177.2875D26S[null]169
3510male51.001PC 1759761.3792[null]C[null][null]
3611female63.0101350277.9583D7S10[null]
3711female32.0001181376.2917D15C8[null]
3811female58.00011378326.55C103S8[null]
3911female44.000PC 1761027.7208B4C6[null]
4011female41.00016966134.5E40C3[null]
4111female53.000PC 1760627.4458[null]C6[null]
4211male36.001PC 17755512.3292B51 B53 B55C3[null]
4311female58.001PC 17755512.3292B51 B53 B55C3[null]
4411male11.012113760120.0B96 B98S4[null]
4511female76.0101987778.85C46S6[null]
4611female[null]0111350555.0E33S6[null]
4711female39.011PC 1775683.1583E49C14[null]
4811female27.012F.C. 1275052.0B71S3[null]
4911female[null]0017421110.8833[null]C4[null]
5011female35.000113503211.5C130C4[null]
5111female22.00111237859.4[null]C7[null]
5211female25.0101176555.4417E50C5[null]
5311male48.010PC 1757276.7292D33C3[null]
5411female35.0103697383.475C83SD[null]
5511male27.000PC 1757276.7292D49C3[null]
5611female24.0001176783.1583C54C7[null]
5711female52.0111274993.5B69S3[null]
5811female44.00111136157.9792B18C4[null]
5911female15.00124160211.3375B5S2[null]
6011male30.0101323657.75C78C11[null]
6111female31.01035273113.275D36C6[null]
6211female39.000PC 17758108.9C105C8[null]
6311female22.00111350961.9792B36C5[null]
6411male52.00011378630.5C104S6[null]
6511female43.00124160211.3375B3S2[null]
6611female33.00011015286.5B77S8[null]
6711male45.01116966134.5E34C3[null]
6811female40.01116966134.5E34C3[null]
6911male48.0101999652.0C126S5 7[null]
7011female[null]00PC 1758579.2[null]CD[null]
7111female35.000PC 17755512.3292[null]C3[null]
7211female60.01011081375.25D37C5[null]
7311male21.001PC 1759761.3792[null]CA[null]
7420male23.000C.A. 3103010.5[null]S[null][null]
7520male28.00024435826.0[null]S[null][null]
7620male60.0112975039.0[null]S[null][null]
7720female44.01024425226.0[null]S[null][null]
7820male29.010200326.0[null]S[null][null]
7920male18.000S.O.C. 1487973.5[null]S[null][null]
8020male18.000S.O.C. 1487973.5[null]S[null][null]
8120male54.0002840326.0[null]S[null][null]
8220male18.00023617113.0[null]S[null][null]
8320male36.00022923613.0[null]S[null]236
8420male34.0102866421.0[null]S[null][null]
8520male21.0102813311.5[null]S[null][null]
8620male21.0102813411.5[null]S[null][null]
8720male24.00023386613.0[null]S[null]155
8820male34.0001223313.0[null]S[null][null]
8920male30.00025065313.0[null]S[null]75
9020male44.00024874613.0[null]S[null]35
9120male49.01222084565.0[null]S[null][null]
9220male21.020S.O.C. 1487973.5[null]S[null][null]
9320male21.000S.O.C. 1487973.5[null]S[null][null]
9420female60.0102406526.0[null]S[null][null]
9520male24.020C.A. 3102931.5[null]S[null][null]
9620male22.020C.A. 3102931.5[null]S[null][null]
9720male35.00023373412.35[null]Q[null][null]
9820male31.000C.A. 1872310.5[null]S[null]165
9920male36.000SC/Paris 216312.875DC[null][null]
10020male[null]00SC/A.3 286115.5792[null]C[null][null]
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(64), "sex" Varchar(20), "age" Numeric(8,4), "sibsp" Integer, "parch" Integer, "ticket" Varchar(20), "fare" Numeric(11,6), "cabin" Varchar(20), "embarked" Varchar(20), "boat" Integer, "body" Integer, "home.dest" Varchar(64))',
 '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
name
Varchar(64)
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(20)
Abc
embarked
Varchar(20)
123
boat
Integer
123
body
Integer
Abc
home.dest
Varchar(64)
110Blackwell, Mr. Stephen Weartmale45.00011378435.5TS[null][null]Trenton, NJ
210Clark, Mr. Walter Millermale27.01013508136.7792C89C[null][null]Los Angeles, CA
310Davidson, Mr. Thorntonmale31.010F.C. 1275052.0B71S[null][null]Montreal, PQ
410Head, Mr. Christophermale42.00011303842.5B11S[null][null]London / Middlesex
510Long, Mr. Milton Clydemale29.00011350130.0D6S[null]126Springfield, MA
610Compton, Mr. Alexander Taylor Jrmale37.011PC 1775683.1583E52C[null][null]Lakewood, NJ
710Evans, Miss. Edith Corsefemale36.000PC 1753131.6792A29C[null][null]New York, NY
810Harris, Mr. Henry Birkhardtmale45.0103697383.475C83S[null][null]New York, NY
910McCarthy, Mr. Timothy Jmale54.0001746351.8625E46S[null]175Dorchester, MA
1010Cairns, Mr. Alexandermale[null]0011379831.0[null]S[null][null][null]
1110Douglas, Mr. Walter Donaldmale50.010PC 17761106.425C86C[null]62Deephaven, MN / Cedar Rapids, IA
1210Giglio, Mr. Victormale24.000PC 1759379.2B86C[null][null][null]
1310Hilliard, Mr. Herbert Henrymale[null]001746351.8625E46S[null][null]Brighton, MA
1410Artagaveytia, Mr. Ramonmale71.000PC 1760949.5042[null]C[null]22Montevideo, Uruguay
1510Carrau, Mr. Jose Pedromale17.00011305947.1[null]S[null][null]Montevideo, Uruguay
1610Futrelle, Mr. Jacques Heathmale37.01011380353.1C123S[null][null]Scituate, MA
1710Harrison, Mr. Williammale40.0001120590.0B94S[null]110[null]
1810Holverson, Mr. Alexander Oskarmale42.01011378952.0[null]S[null]38New York, NY
1910Hoyt, Mr. William Fishermale[null]00PC 1760030.6958[null]C14[null]New York, NY
2010McCaffry, Mr. Thomas Francismale46.0001305075.2417C6C[null]292Vancouver, BC
Rows: 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
name
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)
110Artagaveytia, Mr. Ramonmale71.000PC 1760949.5042[null]C[null]22Montevideo, Uruguay
210Blackwell, Mr. Stephen Weartmale45.00011378435.5TS[null][null]Trenton, NJ
310Cairns, Mr. Alexandermale[null]0011379831.0[null]S[null][null][null]
410Carrau, Mr. Jose Pedromale17.00011305947.1[null]S[null][null]Montevideo, Uruguay
510Clark, Mr. Walter Millermale27.01013508136.7792C89C[null][null]Los Angeles, CA
610Compton, Mr. Alexander Taylor Jrmale37.011PC 1775683.1583E52C[null][null]Lakewood, NJ
710Davidson, Mr. Thorntonmale31.010F.C. 1275052.0B71S[null][null]Montreal, PQ
810Douglas, Mr. Walter Donaldmale50.010PC 17761106.425C86C[null]62Deephaven, MN / Cedar Rapids, IA
910Evans, Miss. Edith Corsefemale36.000PC 1753131.6792A29C[null][null]New York, NY
1010Futrelle, Mr. Jacques Heathmale37.01011380353.1C123S[null][null]Scituate, MA
1110Giglio, Mr. Victormale24.000PC 1759379.2B86C[null][null][null]
1210Harris, Mr. Henry Birkhardtmale45.0103697383.475C83S[null][null]New York, NY
1310Harrison, Mr. Williammale40.0001120590.0B94S[null]110[null]
1410Head, Mr. Christophermale42.00011303842.5B11S[null][null]London / Middlesex
1510Hilliard, Mr. Herbert Henrymale[null]001746351.8625E46S[null][null]Brighton, MA
1610Holverson, Mr. Alexander Oskarmale42.01011378952.0[null]S[null]38New York, NY
1710Hoyt, Mr. William Fishermale[null]00PC 1760030.6958[null]C14[null]New York, NY
1810Long, Mr. Milton Clydemale29.00011350130.0D6S[null]126Springfield, MA
1910McCaffry, Mr. Thomas Francismale46.0001305075.2417C6C[null]292Vancouver, BC
2010McCarthy, Mr. Timothy Jmale54.0001746351.8625E46S[null]175Dorchester, MA
Rows: 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.