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

问题描述

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

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

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

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

我看到了以下内容：

1. https://damyan.blog/post/flask-series-structure/
2. How to execute a block of code only once in flask?
3. Flask at first run: Do not use the development server in a production environment

并尝试使用 #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 服务器和连接到 Binance 服务器的代码只执行一次，而不是每次服务器启动时执行使用 http://:80/

访问

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

TIA

@Christopher Jones 谢谢回复。

我希望做的是拥有这个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 "将看到“调度员”将工作转发到的所有进程）。所以，我正在寻找类似的东西 - 旧习惯很难改掉......

解决方法

大多数 Flask 应用程序将被多个用户调用，因此连接池很重要。见How to use Python Flask with 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 高可用性特性，在应用程序运行期间保持打开独立连接不会提供。