Init commit

Enum/InputTypeEnum.py

+from enum import Enum
+
+
+class InputTypeEnum(Enum):
+    LOCAL = "local"
+    DATABASE = "db"
+    BUCKET = "bucket"
+

Input/Input.py

+
+
+class Input:
+
+    def __init__(self, input_type: str) -> None:
+        self.input_type = input_type

Pipeline/Process.py

+import logging
+
+logger = logging.getLogger()
+

conf.yml

+app:
+  input:
+    type: bucket
+    provider: aws
+
+  output:
+    type: bucket
+    provider: aws

run.py

+import time
+import logging
+
+logger = logging.getLogger()
+
+
+if __name__ == "__main__":
+    start_time = time.time()
+
+    logger.info(f"Duración de ejecución del proceso: {start_time - time.time()}")