From 6d1d9cb7cd5aaca3522d430a7839d749e7e0f2c4 Mon Sep 17 00:00:00 2001 From: "CHIEFSOFT\\ameye" Date: Sun, 1 Sep 2024 16:54:13 -0400 Subject: [PATCH] first commit --- wrenchboard_approvereminder.py | 47 ++++++++++++++++++++++++++++++++++ wrenchboard_duereminder.py | 47 ++++++++++++++++++++++++++++++++++ wrenchboard_newaccount.py | 47 ++++++++++++++++++++++++++++++++++ wrenchboard_offerpending.py | 47 ++++++++++++++++++++++++++++++++++ wrenchboard_signupreport.py | 47 ++++++++++++++++++++++++++++++++++ 5 files changed, 235 insertions(+) create mode 100644 wrenchboard_approvereminder.py create mode 100644 wrenchboard_duereminder.py create mode 100644 wrenchboard_newaccount.py create mode 100644 wrenchboard_offerpending.py create mode 100644 wrenchboard_signupreport.py diff --git a/wrenchboard_approvereminder.py b/wrenchboard_approvereminder.py new file mode 100644 index 0000000..625c6c0 --- /dev/null +++ b/wrenchboard_approvereminder.py @@ -0,0 +1,47 @@ + +from airflow import DAG +from airflow.operators.dummy import DummyOperator +# from airflow.operators.python import PythonOperator +from airflow.operators.python_operator import PythonOperator +from datetime import datetime, timedelta +from airflow.models import Variable + +import requests + +default_args = { + 'owner': 'WrenchBoard', + 'depends_on_past': False, + 'start_date': datetime(2022, 1, 1), + 'email_on_failure': False, + 'email_on_retry': False, + 'retries': 1 +} + + +def WrenchCronApproveReminderApi(**kwargs): + url = kwargs["api_host"] + "/v1/new-account" + querystring= {"testuser":"ameye"} + response = requests.request("GET", url, params=querystring) + print(response.text) + +with DAG( + dag_id="WRENCBOARD_CRON_APPROVEREMINDER", + default_args=default_args, + start_date=datetime(2024, 9, 1, 10, 00), + schedule_interval=timedelta(minutes=360), + catchup=False) as dag: + t1 = PythonOperator( + task_id = "wrenchboard_approvereminder", + python_callable= WrenchCronApproveReminderApi, + op_kwargs={ + "api_host" : Variable.get("API_WRENCHBOARD_HOST") + } + ) + + t2 = DummyOperator( + task_id="end" + ) + + t1 >> t2 + + diff --git a/wrenchboard_duereminder.py b/wrenchboard_duereminder.py new file mode 100644 index 0000000..6523a82 --- /dev/null +++ b/wrenchboard_duereminder.py @@ -0,0 +1,47 @@ + +from airflow import DAG +from airflow.operators.dummy import DummyOperator +# from airflow.operators.python import PythonOperator +from airflow.operators.python_operator import PythonOperator +from datetime import datetime, timedelta +from airflow.models import Variable + +import requests + +default_args = { + 'owner': 'WrenchBoard', + 'depends_on_past': False, + 'start_date': datetime(2022, 1, 1), + 'email_on_failure': False, + 'email_on_retry': False, + 'retries': 1 +} + + +def WrenchCronDueReminderApi(**kwargs): + url = kwargs["api_host"] + "/v1/due-reminder" + querystring= {"testuser":"ameye"} + response = requests.request("GET", url, params=querystring) + print(response.text) + +with DAG( + dag_id="WRENCBOARD_CRON_DUEREMINDER", + default_args=default_args, + start_date=datetime(2024, 9, 1, 10, 00), + schedule_interval=timedelta(minutes=300), + catchup=False) as dag: + t1 = PythonOperator( + task_id = "wrenchboard_duereminder", + python_callable= WrenchCronDueReminderApi, + op_kwargs={ + "api_host" : Variable.get("API_WRENCHBOARD_HOST") + } + ) + + t2 = DummyOperator( + task_id="end" + ) + + t1 >> t2 + + diff --git a/wrenchboard_newaccount.py b/wrenchboard_newaccount.py new file mode 100644 index 0000000..c2fc86b --- /dev/null +++ b/wrenchboard_newaccount.py @@ -0,0 +1,47 @@ + +from airflow import DAG +from airflow.operators.dummy import DummyOperator +# from airflow.operators.python import PythonOperator +from airflow.operators.python_operator import PythonOperator +from datetime import datetime, timedelta +from airflow.models import Variable + +import requests + +default_args = { + 'owner': 'WrenchBoard', + 'depends_on_past': False, + 'start_date': datetime(2022, 1, 1), + 'email_on_failure': False, + 'email_on_retry': False, + 'retries': 1 +} + + +def WrenchCronNewaccountApi(**kwargs): + url = kwargs["api_host"] + "/v1/new-account" + querystring= {"testuser":"ameye"} + response = requests.request("GET", url, params=querystring) + print(response.text) + +with DAG( + dag_id="WRENCBOARD_CRON_NEWACCOUNT", + default_args=default_args, + start_date=datetime(2024, 9, 1, 10, 00), + schedule_interval=timedelta(minutes=360), + catchup=False) as dag: + t1 = PythonOperator( + task_id = "wrench_cron_newaccount", + python_callable= WrenchCronNewaccountApi, + op_kwargs={ + "api_host" : Variable.get("API_WRENCHBOARD_HOST") + } + ) + + t2 = DummyOperator( + task_id="end" + ) + + t1 >> t2 + + diff --git a/wrenchboard_offerpending.py b/wrenchboard_offerpending.py new file mode 100644 index 0000000..a946fb0 --- /dev/null +++ b/wrenchboard_offerpending.py @@ -0,0 +1,47 @@ + +from airflow import DAG +from airflow.operators.dummy import DummyOperator +# from airflow.operators.python import PythonOperator +from airflow.operators.python_operator import PythonOperator +from datetime import datetime, timedelta +from airflow.models import Variable + +import requests + +default_args = { + 'owner': 'WrenchBoard', + 'depends_on_past': False, + 'start_date': datetime(2022, 1, 1), + 'email_on_failure': False, + 'email_on_retry': False, + 'retries': 1 +} + + +def WrenchCronOfferPendingApi(**kwargs): + url = kwargs["api_host"] + "/v1/offer-pending" + querystring= {"testuser":"ameye"} + response = requests.request("GET", url, params=querystring) + print(response.text) + +with DAG( + dag_id="WRENCBOARD_CRON_OFFERPENDING", + default_args=default_args, + start_date=datetime(2024, 9, 1, 10, 00), + schedule_interval=timedelta(minutes=2), + catchup=False) as dag: + t1 = PythonOperator( + task_id = "wrenchboard_offerpending", + python_callable= WrenchCronOfferPendingApi, + op_kwargs={ + "api_host" : Variable.get("API_WRENCHBOARD_HOST") + } + ) + + t2 = DummyOperator( + task_id="end" + ) + + t1 >> t2 + + diff --git a/wrenchboard_signupreport.py b/wrenchboard_signupreport.py new file mode 100644 index 0000000..ed247ad --- /dev/null +++ b/wrenchboard_signupreport.py @@ -0,0 +1,47 @@ + +from airflow import DAG +from airflow.operators.dummy import DummyOperator +# from airflow.operators.python import PythonOperator +from airflow.operators.python_operator import PythonOperator +from datetime import datetime, timedelta +from airflow.models import Variable + +import requests + +default_args = { + 'owner': 'WrenchBoard', + 'depends_on_past': False, + 'start_date': datetime(2022, 1, 1), + 'email_on_failure': False, + 'email_on_retry': False, + 'retries': 1 +} + + +def WrenchCronSignUpReportApi(**kwargs): + url = kwargs["api_host"] + "/v1/signup-report" + querystring= {"testuser":"ameye"} + response = requests.request("GET", url, params=querystring) + print(response.text) + +with DAG( + dag_id="WRENCBOARD_CRON_SIGNUPREPORT", + default_args=default_args, + start_date=datetime(2024, 9, 1, 10, 00), + schedule_interval=timedelta(minutes=120), + catchup=False) as dag: + t1 = PythonOperator( + task_id = "wrenchboard_signupreport", + python_callable= WrenchCronSignUpReportApi, + op_kwargs={ + "api_host" : Variable.get("API_WRENCHBOARD_HOST") + } + ) + + t2 = DummyOperator( + task_id="end" + ) + + t1 >> t2 + +