diff --git a/dags/OSV.py b/dags/OSV.py index 3de12ed..11f054c 100644 --- a/dags/OSV.py +++ b/dags/OSV.py @@ -51,8 +51,10 @@ def read_data_1C(**kwargs): ) data_from_1c = response.json() - # df = pd.DataFrame(data_from_1c['data']) - return data_from_1c['data'] + df = pd.DataFrame() + for data in data_from_1c['data']: + df.loc[len(df)] = data + return df with DAG( dag_id='data_download_from_1C_source',