我该怎么做才能在 Flask 应用程序中使用dramatiq

如何解决我该怎么做才能在 Flask 应用程序中使用dramatiq

按照本教程 https://github.com/Bogdanp/dramatiq 我创建了一个简单的 python 脚本来检查它是否有效。我做了一些简单的操作如下

效果很好。

请注意有两个终端， 一个用于运行脚本，一个用于工作人员，在下面给出的脚本中，count_word 函数中的打印语句在第二个终端中执行

working example
import pandas as pd
import dramatiq
import requests
import sys

@dramatiq.actor
def count_words(url):
    response = requests.get(url)
    count = len(response.text.split(" "))


    data = {'Name': ['Tom','nick','krish','jack'],'Age': [20,21,19,18]}

    df = pd.DataFrame(data)

    df.to_csv(r'C:\Users\91956\Desktop\asdf.csv')
    print(df)
    print(f"There are {count} words at {url!r}.")


if __name__ == "__main__":
    count_words.send("http://whatsapp.com")

所以我继续尝试在我的烧瓶应用程序中做同样的事情，我希望 process_data 中的打印语句会在工作终端中打印，但它根本没有打印， 只有“嗨，我在工作”会打印在我运行 Flask 应用程序的终端中

@app.route('/work')
def work():

    print("hi i am in work")    
    
    @dramatiq.actor
    def process_data():
        print('hi i am in process_data')
    
    process_data.send()
    
    return "hello"

我想在后台运行 process_data 函数， 我是初学者，不太了解，有可能按照我的方式实现吗？

所以我想知道如何在flask的后台运行特定功能？