CSV

class airflow_plugins.operators.csv.CSVLook(bash_command=None, *args, **kwargs)

Get stats of the CSV file

class airflow_plugins.operators.csv.CSVSQL(bash_command=None, *args, **kwargs)

Use csvsql tool for migration CSV to SQL. For more parameters check csvsql.

class airflow_plugins.operators.csv.CSVStats(bash_command=None, *args, **kwargs)

Get stats of the CSV file Use csvstat.

class airflow_plugins.operators.csv.CSVtoDB(bash_command=None, *args, **kwargs)

Use csvsql tool for migration csv to SQL database. For more parameters check csvsql.

class airflow_plugins.operators.csv.SplitCSVtoDB(bash_command=None, *args, **kwargs)

Split CSV and upload to DB.