Dynamisch Einstellung Flask-SQLAlchemy Datenbankverbindung in Multi-Tenant-App

Question

Ich habe einen "Multi-Tenant" Flask Web-Anwendung, die mit 1 "Master" MySQL-Datenbank-Schnittstellen (verwendet, um die Client-Informationen nachschlagen) und Dutzenden von "Client" MySQL-Datenbanken (die alle das gleiche Schema haben).

Ich versuche derzeit SQLAlchemy zusammen mit der Flask-SQLAlchemy Erweiterung Schnittstelle mit den Datenbanken zu verwenden, aber ich bin zu kämpfen, einen Weg zu finden, den Model ich in meiner App definieren zu ermöglichen dynamisch wechseln Kontext von einer Client-Datenbank zu einem anderen, je nach Client.

Auf den Flask-SQLAlchemy site, ein einfaches Beispiel ist entlang der Linien gezeigt:

from flask import Flask 
from flask.ext.sqlalchemy import SQLAlchemy 

app = Flask(__name__) 
app.config['SQLALCHEMY_DATABASE_URI'] = 'mysql://username:password@Y.Y.Y.Y/db1' 
db = SQLAlchemy(app) 

class User(db.Model): 
    # Etc. 

Das einzige Problem ist, die SQLALCHEMY_DATABASE_URI Konfiguration statisch erfolgt. Möglicherweise muss ich zwischen mysql://username:password@Y.Y.Y.Y/db1 und mysql://username:password@Z.Z.Z.Z/db1 (oder einem beliebigen anderen MySQL-URI) wechseln, je nachdem, welcher Client die Anfrage stellt.

Ich habe einige ähnliche Fragen (siehe unten) gefunden, aber ich habe noch einen sauberen Weg, um es zu tun, wenn Sie speziell die Erweiterung Flask-SQLAlchemy tun.

With sqlalchemy how to dynamically bind to database engine on a per-request basis

Flask SQLAlchemy setup dynamic URI

Ich habe auch einige Beispiele gesehen, die für den Umgang mit sharded Datenbanken zur Verfügung gestellt wurden (die auch gelten sollte, da die Datenbanken im Wesentlichen logisch durch Client sharded), aber auch hier nichts Besonderes zu Flask-SQLAlchemy.

Wenn es Sinn macht, Ich bin auch offen für die Verwendung von SQLAlchemy direkt, ohne die Flask-SQLAlchemy-Erweiterung. Ich bin neu in SQLAlchemy - jede Hilfe würde sehr geschätzt werden!

Bearbeiten: Die Tabelle Schemata aus der Datenbank widerspiegeln könnte ein Bonus sein.

Answer 1

Sie könnten so etwas tun. FYI das ist reine SQLAlchemy, nicht mit Flask-SQLAlchemy. Hoffentlich brauchen Sie das für nur-Lese-Sachen. Sie können einige andere Sachen herauszufinden, zu haben Sachen zu schreiben, wie auch die Zuhörer auf Ihrer Sitzung/Modelle

from sqlalchemy import create_engine 
from sqlalchemy.orm import sessionmaker 
from sqlalchemy.ext.declarative import declarative_base 

# an Engine, which the Session will use for connection 
# resources 
some_engine_1 = create_engine('postgresql://scott:tiger@localhost/') 
some_engine_2 = create_engine('postgresql://adriel:velazquez@localhost/') 

# create a configured "Session" class 
Session_1 = sessionmaker(bind=some_engine_1) 
Session_2 = sessionmaker(bind=some_engine_2) 

# create a Session 
session_1 = Session_1() 
session_2 = Session_2() 

Base = declarative_base() 

class ModelBase(Base): 
    #different custom queries for each database 
    master_query = session_1.query_property() 
    client_1_query = session_2.query_property() 


class User(ModelBase): 
    pass 
    #ETC 


##Accessing the different databases: 
User.master_query.filter(User.id == 1).all() 
User.client_1_query.filter(User.id == 1).all() 

Answer 2

Wenn Sie mit Kolben-sqlalchemy 0,12 oder später wird diese Funktion mit Bindet unterstützt.

SQLALCHEMY_DATABASE_URI = 'postgres://localhost/main' 
SQLALCHEMY_BINDS = { 
'users':  'mysqldb://localhost/users', 
'appmeta':  'sqlite:////path/to/appmeta.db' 
} 

Und Sie können Verbindungsdatenbank in der Modelldefinition angeben.

class User(db.Model): 
    __bind_key__ = 'users' 
    id = db.Column(db.Integer, primary_key=True) 
    username = db.Column(db.String(80), unique=True) 

Es wird die mysqldb Auto verwenden. Für weitere Details können Sie das offizielle Dokument beziehen. Multiple Databases with Binds