<filename>dags/simple_athena.py<gh_stars>0
from airflow.models import DAG
from airflow.contrib.operators.aws_athena_operator import AWSAthenaOperator
from datetime import datetime

with DAG(dag_id='simple_athena_query',
         schedule_interval=None,
         start_date=datetime(2019, 11, 21)) as dag:

    run_query = AWSAthenaOperator(
        task_id='run_query',
        query='SELECT * FROM  airbnb(SEQUENCE(0, 100))',
        output_location='s3://joy-friday/data/',
        database='airbnb')
<filename>dags/simple_athena.py<gh_stars>0
from airflow.models import DAG
from airflow.contrib.operators.aws_athena_operator import AWSAthenaOperator
from datetime import datetime

with DAG(dag_id='simple_athena_query',
         schedule_interval=None,
         start_date=datetime(2019, 11, 21)) as dag:

    run_query = AWSAthenaOperator(
        task_id='run_query',
        query='SELECT * FROM  airbnb(SEQUENCE(0, 100))',
        output_location='s3://joy-friday/data/',
        database='airbnb')