diff --git a/dags/OSV.py b/dags/OSV.py index 182577a..773b3a8 100644 --- a/dags/OSV.py +++ b/dags/OSV.py @@ -1,9 +1,19 @@ import requests import json import pandas as pd -from requests.auth import HTTPBasicAuth +import numpy as np import datetime +from requests.auth import HTTPBasicAuth from sqlalchemy import create_engine +from airflow import DAG +from airflow.operators.python import PythonOperator + +default_args = { + 'owner': 'airflow', + 'depends_on_past': False, + 'start_date': datetime(2023, 1, 1), + 'retries': 1, +} def get_db_engine(): """Создает подключение к PostgreSQL"""