| :py:mod:`tests.system.providers.amazon.aws.example_athena` |
| ========================================================== |
| |
| .. py:module:: tests.system.providers.amazon.aws.example_athena |
| |
| |
| Module Contents |
| --------------- |
| |
| |
| Functions |
| ~~~~~~~~~ |
| |
| .. autoapisummary:: |
| |
| tests.system.providers.amazon.aws.example_athena.await_bucket |
| tests.system.providers.amazon.aws.example_athena.read_results_from_s3 |
| |
| |
| |
| Attributes |
| ~~~~~~~~~~ |
| |
| .. autoapisummary:: |
| |
| tests.system.providers.amazon.aws.example_athena.ENV_ID |
| tests.system.providers.amazon.aws.example_athena.DAG_ID |
| tests.system.providers.amazon.aws.example_athena.S3_BUCKET |
| tests.system.providers.amazon.aws.example_athena.ATHENA_TABLE |
| tests.system.providers.amazon.aws.example_athena.ATHENA_DATABASE |
| tests.system.providers.amazon.aws.example_athena.SAMPLE_DATA |
| tests.system.providers.amazon.aws.example_athena.SAMPLE_FILENAME |
| tests.system.providers.amazon.aws.example_athena.QUERY_CREATE_DATABASE |
| tests.system.providers.amazon.aws.example_athena.QUERY_CREATE_TABLE |
| tests.system.providers.amazon.aws.example_athena.QUERY_READ_TABLE |
| tests.system.providers.amazon.aws.example_athena.QUERY_DROP_TABLE |
| tests.system.providers.amazon.aws.example_athena.QUERY_DROP_DATABASE |
| tests.system.providers.amazon.aws.example_athena.create_s3_bucket |
| tests.system.providers.amazon.aws.example_athena.test_run |
| |
| |
| .. py:data:: ENV_ID |
| |
| |
| |
| |
| .. py:data:: DAG_ID |
| :annotation: = example_athena |
| |
| |
| |
| .. py:data:: S3_BUCKET |
| |
| |
| |
| |
| .. py:data:: ATHENA_TABLE |
| |
| |
| |
| |
| .. py:data:: ATHENA_DATABASE |
| |
| |
| |
| |
| .. py:data:: SAMPLE_DATA |
| :annotation: = Multiline-String |
| |
| .. raw:: html |
| |
| <details><summary>Show Value</summary> |
| |
| .. code-block:: text |
| :linenos: |
| |
| "Alice",20 |
| "Bob",25 |
| "Charlie",30 |
| |
| |
| .. raw:: html |
| |
| </details> |
| |
| |
| |
| .. py:data:: SAMPLE_FILENAME |
| :annotation: = airflow_sample.csv |
| |
| |
| |
| .. py:data:: QUERY_CREATE_DATABASE |
| |
| |
| |
| |
| .. py:data:: QUERY_CREATE_TABLE |
| |
| |
| |
| |
| .. py:data:: QUERY_READ_TABLE |
| |
| |
| |
| |
| .. py:data:: QUERY_DROP_TABLE |
| |
| |
| |
| |
| .. py:data:: QUERY_DROP_DATABASE |
| |
| |
| |
| |
| .. py:function:: await_bucket() |
| |
| |
| .. py:function:: read_results_from_s3(query_execution_id) |
| |
| |
| .. py:data:: create_s3_bucket |
| |
| |
| |
| |
| .. py:data:: test_run |
| |
| |
| |
| |
