如何在不使用请求的情况下直接从代码调用烧瓶端点

Question

大家好，几天前我的任务是创建一个 API 风格的应用程序，它通过 TCP 套接字侦听一些命令，然后返回一些响应，主要是成功/失败（我知道这很愚蠢，但它是客户端请求），因为我有一些验证/数据库的东西我直接想到了烧瓶，但我仍然坚持如何直接调用代码中的特定端点。这是一个关于我想象的事情的小sn-p

from flask import Flask                                                         
import threading

data = 'foo'
app = Flask(__name__)

@app.route("/SomeCommand")
def SomeCommand():
    return { 'Some' : 'Response'}

def flaskThread():
    app.run()


def TcpListenner():
    # logic that listens over tcp socket then invoks the flask app
    # I was thinking about calling app.something() from here
    pass

if __name__ == "__main__":
    flaskApp = threading.Thread(target=flaskThread)
    flaskApp.start()
    listenner = threading.Thread(target=TcpListenner)
    listenner.start()

任何帮助/想法将不胜感激，谢谢

Answer 1

您可以使用 flask_socketio，flask 应用程序和套接字（即 tcp 侦听器）一起启动... 根据我的理解，你可以这样做：

客户端将首先连接到烧瓶套接字。

然后，为了向烧瓶应用程序发送命令，客户端将向烧瓶套接字发送一条消息，其中包含该命令。

烧瓶套接字将监听消息。因此，当它接收到特定命令的消息时，它会根据该命令向套接字发出响应，然后客户端将接收该响应。

以下是烧瓶套接字应用程序的示例代码：

import eventlet
eventlet.monkey_patch()

from flask import Flask
from flask_socketio import SocketIO, send, emit

app = Flask(__name__)
socketio = SocketIO(app, cors_allowed_origins="*", logger=True, engineio_logger=True)

# other flask APIs can come here and can be called by the client...

def someCommandOneResponse(): # function that sends response to client when flask socket gets command 1
    commandOneResponse = 'Success'
    socketio.emit('message', commandOneResponse)

def someCommandTwoResponse(): # function that sends response to client when flask socket gets command 2
    commandTwoResponse = 'Failure'
    socketio.emit('message', commandTwoResponse)

@socketio.on('message') # when any command is received on the socket from the client
def handleMessage(cmd):
    print('\nCommand Received: ' + cmd + '\n')

    if( cmd == 'SomeCommand1' ): # if the client has sent a message for command 1
        print('Got Some Command 1')
        someCommandOneResponse()
        
    elif( cmd == 'SomeCommand2' ): # if the client has sent a message for command 2
        print('Got Some Command 2')
        someCommandTwoResponse
    
    send(cmd, broadcast=True)

if __name__ == '__main__':
    socketio.run(app, port=3000) # starts the flask socket (tcp listener) as well as the flask app