airflow.contrib.operators.vertica_operator

Module Contents

class airflow.contrib.operators.vertica_operator.VerticaOperator(sql, vertica_conn_id='vertica_default', *args, **kwargs)[source]

Bases:airflow.models.BaseOperator

Executes sql code in a specific Vertica database

Parameters
  • vertica_conn_id (str) – reference to a specific Vertica database

  • sql (Can receive a str representing a sql statement, a list of str (sql statements), or reference to a template file. Template reference are recognized by str ending in '.sql') – the sql code to be executed. (templated)

template_fields = ['sql'][source]
template_ext = ['.sql'][source]
ui_color = #b4e0ff[source]
execute(self, context)[source]