Conexiones múltiples de base de datos utilizando fastapi

Answer

1. 

   davy.ai

   May 31, 2023 at 6:20 pm

   ¡Hola!

   Conectar a múltiples bases de datos en FastAPI se puede hacer usando SQLAlchemy, en lo cual mencionaste que te especializas. Una forma de conectar a múltiples bases de datos es creando motores de base de datos separados dentro de la misma aplicación de FastAPI. Aquí tienes un ejemplo:

   from fastapi import FastAPI
   from sqlalchemy import create_engine
   from sqlalchemy.orm import sessionmaker
   
   app = FastAPI()
   
   # crear un motor para database1
   engine1 = create_engine('postgresql://user:password@database1_host/database1')
   
   # crear un motor para database2
   engine2 = create_engine('postgresql://user:password@database2_host/database2')
   
   # crear una fábrica de sesión
   Session = sessionmaker()
   
   # unir la fábrica de sesión a cada motor
   Session.configure(bind=engine1)
   session1 = Session()
   
   Session.configure(bind=engine2)
   session2 = Session()
   
   # definir ruta para consultar datos de database1 usando session1
   @app.get('/data1')
   def get_data1():
       data = session1.query(SomeTable).all()
       return data
   
   # definir ruta para consultar datos de database2 usando session2
   @app.get('/data2')
   def get_data2():
       data = session2.query(AnotherTable).all()
       return data
   

   En este ejemplo, creamos dos motores de base de datos (engine1 y engine2) y los unimos a sesiones separadas (session1 y session2). Esto nos permite consultar datos de diferentes bases de datos dentro de la misma aplicación de FastAPI.

   En cuanto a consultar y actualizar datos, puedes usar el método query de SQLAlchemy para consultar datos y el método update para actualizar los valores en la base de datos. Aquí tienes un ejemplo:

   # consultar datos de database1 usando session1
   data = session1.query(SomeTable).filter(SomeTable.id == 1).all()
   
   # actualizar datos en database1 usando session1
   record = session1.query(SomeTable).filter(SomeTable.id == 1).first()
   record.columna = nuevo_valor
   session1.commit()
   

   ¡Espero que esto te ayude! Si tienes cualquier otra pregunta, no dudes en preguntar. Además, hay muchos otros ejemplos y métodos disponibles en el sitio web de documentación de SQLAlchemy: https://docs.sqlalchemy.org/en/14/orm/index.html

Comments are closed.