We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent f25a69f commit 99b51c6Copy full SHA for 99b51c6
airflow/dags/gasolina_s3.py
@@ -1,5 +1,4 @@
1
import json
2
-import socket
3
4
from datetime import datetime
5
@@ -60,8 +59,6 @@ def filtrado_s3(contexto, codigo_postal):
60
59
@task
61
def almacenamiento_s3(contexto):
62
print("Almacenando datos... Nothing to do!")
63
- import socket
64
- print("hostname:", socket.gethostname())
65
return 42
66
67
todos_los_datos = recogida_s3()
@@ -72,3 +69,4 @@ def almacenamiento_s3(contexto):
72
69
73
70
# Additionally, use Amazon operator, particularly S3KeySensor
74
71
# https://airflow.apache.org/docs/apache-airflow-providers-amazon/stable/operators/s3.html
+# https://github.com/apache/airflow/tree/main/airflow/providers/amazon/aws/example_dags
0 commit comments