cuando ejecuto la interfaz de usuario de flujo de aire y la actualizo para actualizar el DAG, aparece el error que dice que no hay módulo pymongo. Así que traté de ponerlo en requirements.txt y usarlo por volúmenes. También lo he instalado en cli. Pero el error no va.
¿Hay alguna manera adecuada de que podamos usar la técnica etl usando python en el DAG?
pip install -r requirements.txt pip install pymongo import pymongo from pymongo import MongoClient client = pymongo.MongoClient(---)Amablemente necesita sugerencias al respecto.
Debe crear su propia imagen de Airlfow con dependencias adicionales si las instaladas de forma predeterminada no son suficientes para usted.
Esto se describe en detalle en la documentación, con muchos ejemplos y explicaciones sobre cuándo y cómo debe construir la imagen.