| :mod:`airflow.providers.amazon.aws.transfers.exasol_to_s3` |
| ========================================================== |
| |
| .. py:module:: airflow.providers.amazon.aws.transfers.exasol_to_s3 |
| |
| .. autoapi-nested-parse:: |
| |
| Transfers data from Exasol database into a S3 Bucket. |
| |
| |
| |
| Module Contents |
| --------------- |
| |
| .. py:class:: ExasolToS3Operator(*, query_or_table: str, key: str, bucket_name: Optional[str] = None, replace: bool = False, encrypt: bool = False, gzip: bool = False, acl_policy: Optional[str] = None, query_params: Optional[Dict] = None, export_params: Optional[Dict] = None, exasol_conn_id: str = 'exasol_default', aws_conn_id: str = 'aws_default', **kwargs) |
| |
| Bases: :class:`airflow.models.BaseOperator` |
| |
| Export data from Exasol database to AWS S3 bucket. |
| |
| :param query_or_table: the sql statement to be executed or table name to export |
| :type query_or_table: str |
| :param key: S3 key that will point to the file |
| :type key: str |
| :param bucket_name: Name of the bucket in which to store the file |
| :type bucket_name: str |
| :param replace: A flag to decide whether or not to overwrite the key |
| if it already exists. If replace is False and the key exists, an |
| error will be raised. |
| :type replace: bool |
| :param encrypt: If True, the file will be encrypted on the server-side |
| by S3 and will be stored in an encrypted form while at rest in S3. |
| :type encrypt: bool |
| :param gzip: If True, the file will be compressed locally |
| :type gzip: bool |
| :param acl_policy: String specifying the canned ACL policy for the file being |
| uploaded to the S3 bucket. |
| :type acl_policy: str |
| :param query_params: Query parameters passed to underlying ``export_to_file`` |
| method of :class:`~pyexasol.connection.ExaConnection`. |
| :type query_params: dict |
| :param export_params: Extra parameters passed to underlying ``export_to_file`` |
| method of :class:`~pyexasol.connection.ExaConnection`. |
| :type export_params: dict |
| |
| .. attribute:: template_fields |
| :annotation: = ['query_or_table', 'key', 'bucket_name', 'query_params', 'export_params'] |
| |
| |
| |
| .. attribute:: template_fields_renderers |
| |
| |
| |
| |
| .. attribute:: template_ext |
| :annotation: = ['.sql'] |
| |
| |
| |
| .. attribute:: ui_color |
| :annotation: = #ededed |
| |
| |
| |
| |
| .. method:: execute(self, context) |
| |
| |
| |
| |