Flask API 回调监听器

Question

我是 Flask 的新手，正致力于创建一个 Web 应用程序，该应用程序将使用来自我们 API 的回调 URL 监听和监控状态更新。如果执行特定事件，应用程序将以 pdf 格式下载文件。

应用程序将使用用户的集成密钥访问管理控制台。该应用会将用户引导至 selection 屏幕，用户将在下载选项之间进入 select。

@app.route('/tool', methods=['GET', 'POST'])
def tool():

# Empty dict
agreement_list = {}

# Iterate through session cookies to extract out the name & agreement ID
for agreement in session['agreementID']['userAgreementList']:
    if agreement['esign'] == True and agreement['status'] != 'SIGNED':
        agreement_list[agreement['name']] = agreement['agreementId']

# If the user clicks the download button
if request.method == 'POST':

    # extract the data from the selection field
    session['config_selected'] = request.form.get('select_name')

    # Store into session
    session['agreements'] = agreement_list

    return redirect(url_for('scan'))

return render_template('tool.html', agreements=agreement_list)

单击该按钮后，该应用程序会将用户引导至一个页面，该页面将监视更新并在有更新时下载文件。

@app.route('/scan', methods=['Get'])
def scan():

def createPDF(file_selected, agreementID, config_selected):
    """
    This sub function will create a pdf requested by the user. It will use an API call
    depending on which file is selected. It does both single and multiple pdf creations.
    :param page_id: A list of selected downloading option the user selected
    :param agreementID: Agreement ID that the user selected
    :param select: name of the selected file use to help name pdf
    :return: N/A
    """
    # Iterate through the list of selected options that the user selected
    for file in file_selected:

        # API request
        r = requests.get('Some request url from API' + agreementID + file,
                         headers=session['header'])

        file_name = config_selected + ' - ' + id[1:] + '.pdf'
        file_name = file_name.replace(' ', '_')

        # Write file to pdf
        with open(file_name, 'wb') as f:
            f.write(r.content)

    f.close()

    # call createPDF here


return render_template('scan.html')

尝试次数

经过研究，我发现我应该使用套接字来进行服务器和客户端之间的通信。我尝试实现 Flask-SocketIO 并得到它运行。

@socketio.on('message')
def handleMessage(msg):
    print('Message: ' + msg)
    send(msg, broadcast=True)

目前该应用程序运行在我的本地计算机上，它目前能够在该特定页面上进行轮询。

$(document).ready(function () {
    var socket = io.connect('http://127.0.0.1:5000');

    socket.on('connect', function () {
        socket.send('User has connected!');
    });

    // socket.on('message', function () {
    //     socket.send('Scanning')
    // });

});

问题：

当最终用户执行我正在寻找的任务时，我如何获得实时回调更新？我是否必须将套接字连接到 API 服务器以进行回调？或者有没有其他方法可以使用集成密钥获取回调更新，因为我可以使用 HTTP 请求访问管理 UI。

Answer 1

我终于弄清楚出了什么问题以及为什么我没有从 API 服务器收到任何事件 ping。事实证明，我的本地主机需要 public 可访问才能从服务器接收事件更改。我的解决方案是让我们 ngrok 创建一个从我的本地主机到 public 端点的安全隧道。实现后，我添加了回调 url，这又允许服务器通过事件更改对我执行 ping 操作。

Flask API 回调监听器

Flask API Callback Listener

python

web-applications

flask

flask-socketio

尝试次数

问题：