python服务器每次访问系统时执行DB/币安连接

Question

我正在使用Python和Flask作为服务器的一部分。当服务器启动时，它会连接到Oracle数据库并Binance Crypto Exchange服务器

服务器以TEST或PRODUCTION模式启动。为了确定启动时使用的模式，我取了一个input variable，然后使用它来确定是否连接到 PROD 配置(实际执行交易)和 TEST 系统(更像是一个沙箱)

每当我调用服务器(例如：http://<myservername.com>:80/)时，似乎每次调用都会执行服务器连接。因此，如果我输入 http://：80/7 次，连接到数据库的代码(以及连接到币安服务器的代码)将执行 7 次。

问题：有没有一个地方可以放置连接代码，以便在服务器启动时执行一次？

我看到了以下内容：

1. https://damyan.blog/post/flask-series-structure/
2. 如何在烧瓶中只执行一次代码块？
3. 首次运行时的烧瓶：不要在生产环境中使用开发服务器

并尝试使用#2中的解决方案

@app.before_first_request
def do_something_only_once():

代码已更改，因此如下所示(未显示与币安服务器的连接)：

@app.before_first_request
def do_something_only_once():
system_access = input(" Enter the system access to use n-> ")
if ( system_access.upper() == "TEST" ) :
global_STARTUP_DB_SERVER_MODE   = t_system_connect.DBSystemConnection.DB_SERVER_MODE_TEST
print(" connected to TEST database")
if ( system_access.upper() == "PROD" ) :
global_STARTUP_DB_SERVER_MODE   = t_system_connect.DBSystemConnection.DB_SERVER_MODE_PROD
print(" connected to PRODUCTION database")

启动服务器时，我从来没有机会输入"TEST"(为了连接到"TEST"数据库)。实际上，代码下的区域为：

@app.before_first_request
def do_something_only_once():

根本不执行。

问题：如何修复代码，以便在服务器启动时，负责连接到Oracle DB服务器并连接到币安服务器的代码仅执行一次，而不是每次使用 http://：80访问服务器时执行一次/

任何帮助，提示或建议将不胜感激

蒂亚

@Christopher琼斯感谢您的回复。

我希望做的是拥有这个Flask server implemented as a Docker process。这个想法是一次启动其中的几个过程。然后，Docker Processes组将由某种Dispatcher管理。当执行http://myservername.com:80/命令时，连接信息将首先转到Dispatcher， 会将其转发到"免费"使用的 Docker 进程。我的想法是Docker Swarm(或Kubernetes下的东西)可能会以这种方式工作(？)：一个进程获得一个与数据库的连接(调度程序将负责分发工作)。

我来自ERP背景。Oracle Connection Pool的存在是已知的，但它被选择将大部分工作转移到操作系统处理级别(因为如果运行"ps -ef | grep"，他们将看到"调度程序"将工作转发到的所有进程)。所以，我一直在寻找类似的东西 - 旧习惯很难改变......

Answer 1

大多数 Flask 应用将由多个用户调用，因此连接池很重要。 请参阅如何将 Python Flask 与 Oracle Database 配合使用。

您可以在启动时打开连接池：

if __name__ == '__main__':

# Start a pool of connections
pool = start_pool()
...

(start_pool()调用cx_Oracle.SessionPool()- 完整示例请参阅链接)

然后，您的路由根据需要从池中借用连接：

    connection = pool.acquire()
    cursor = connection.cursor()
    cursor.execute("select username from demo where id = :idbv", [id])
    r = cursor.fetchone()
    return (r[0] if r else "Unknown user id")

即使只需要一个连接，一个连接的池也很有用，因为它提供了一些 Oracle 高可用性功能，这些功能在应用程序运行期间保持打开独立连接不会提供。