我有一些代码需要在 Flask 返回响应后执行。我认为为它设置像 Celery 这样的任务队列还不够复杂。关键要求是 Flask 必须在运行此函数之前将响应返回给客户端。它不能等待函数执行。
对此存在一些现有问题,但似乎没有一个答案涉及在响应发送到客户端后运行任务,它们仍然同步执行然后返回响应。
最佳答案
长话短说,Flask 没有提供任何特殊功能来实现这一点。对于简单的一次性任务,请考虑 Python 的多线程,如下所示。对于更复杂的配置,请使用 RQ 或 Celery 等任务队列。
了解 Flask 提供的功能以及它们没有实现预期目标的原因很重要。所有这些都在其他情况下很有用并且是很好的阅读,但对后台任务没有帮助。
after_request 处理程序Flask 的 after_request 处理程序,详见 this pattern for deferred request callbacks和 this snippet on attaching different functions per request ,将请求传递给回调函数。预期的用例是修改请求,例如附加一个cookie。
因此,请求将等待这些处理程序完成执行,因为期望请求本身会因此而改变。
teardown_request 处理程序这类似于 after_request,但 teardown_request 不接收 request 对象。所以这意味着它不会等待请求,对吧?
这似乎是解决方案,如 this answer to a similar Stack Overflow question建议。由于 Flask 的文档解释了 teardown callbacks are independent of the actual request并且没有收到请求上下文,您有充分的理由相信这一点。
不幸的是,teardown_request 仍然是同步的,它只是发生在 Flask 请求处理的后期,当请求不再可修改时。在返回响应之前,Flask 仍将等待拆卸函数完成,如 this list of Flask callbacks and errors指示。
Flask 可以通过将生成器传递给 Response() 来流式传输响应,如 this Stack Overflow answer to a similar question建议。
通过流式传输,客户端确实在请求结束之前开始接收响应。但是,请求仍然是同步运行的,所以处理请求的 worker 一直忙到流结束。
This Flask pattern for streaming包括一些关于使用 stream_with_context() 的文档,这是包含请求上下文所必需的。
Flask 不提供在后台运行函数的解决方案,因为这不是 Flask 的责任。
在大多数情况下,解决此问题的最佳方法是使用 RQ 或 Celery 等任务队列。它们为您管理诸如配置、调度和分配工作人员等棘手的事情。这是此类问题的最常见答案,因为它是最正确的,并迫使您以您考虑上下文等的方式进行设置。正确。
如果你需要在后台运行一个函数并且不想设置一个队列来管理这个,你可以使用 Python 的内置 threading或 multiprocessing产生一个后台工作人员。
您不能从后台任务访问 request 或其他 Flask 的线程本地,因为请求不会在那里事件。相反,在创建 View 时将所需的数据从 View 传递到后台线程。
@app.route('/start_task')
def start_task():
def do_work(value):
# do something that takes a long time
import time
time.sleep(value)
thread = Thread(target=do_work, kwargs={'value': request.args.get('value', 20)})
thread.start()
return 'started'
关于python - Flask 返回响应后执行一个函数,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/48994440/
关闭。这个问题是opinion-based.它目前不接受答案。想要改进这个问题?更新问题,以便editingthispost可以用事实和引用来回答它.关闭4年前。Improvethisquestion我想在固定时间创建一系列低音和高音调的哔哔声。例如:在150毫秒时发出高音调的蜂鸣声在151毫秒时发出低音调的蜂鸣声200毫秒时发出低音调的蜂鸣声250毫秒的高音调蜂鸣声有没有办法在Ruby或Python中做到这一点?我真的不在乎输出编码是什么(.wav、.mp3、.ogg等等),但我确实想创建一个输出文件。
我在使用omniauth/openid时遇到了一些麻烦。在尝试进行身份验证时,我在日志中发现了这一点:OpenID::FetchingError:Errorfetchinghttps://www.google.com/accounts/o8/.well-known/host-meta?hd=profiles.google.com%2Fmy_username:undefinedmethod`io'fornil:NilClass重要的是undefinedmethodio'fornil:NilClass来自openid/fetchers.rb,在下面的代码片段中:moduleNetclass
使用带有Rails插件的vim,您可以创建一个迁移文件,然后一次性打开该文件吗?textmate也可以这样吗? 最佳答案 你可以使用rails.vim然后做类似的事情::Rgeneratemigratonadd_foo_to_bar插件将打开迁移生成的文件,这正是您想要的。我不能代表textmate。 关于ruby-使用VimRails,您可以创建一个新的迁移文件并一次性打开它吗?,我们在StackOverflow上找到一个类似的问题: https://sta
我需要从一个View访问多个模型。以前,我的links_controller仅用于提供以不同方式排序的链接资源。现在我想包括一个部分(我假设)显示按分数排序的顶级用户(@users=User.all.sort_by(&:score))我知道我可以将此代码插入每个链接操作并从View访问它,但这似乎不是“ruby方式”,我将需要在不久的将来访问更多模型。这可能会变得很脏,是否有针对这种情况的任何技术?注意事项:我认为我的应用程序正朝着单一格式和动态页面内容的方向发展,本质上是一个典型的网络应用程序。我知道before_filter但考虑到我希望应用程序进入的方向,这似乎很麻烦。最终从任何
我想要做的是有2个不同的Controller,client和test_client。客户端Controller已经构建,我想创建一个test_clientController,我可以使用它来玩弄客户端的UI并根据需要进行调整。我主要是想绕过我在客户端中内置的验证及其对加载数据的管理Controller的依赖。所以我希望test_clientController加载示例数据集,然后呈现客户端Controller的索引View,以便我可以调整客户端UI。就是这样。我在test_clients索引方法中试过这个:classTestClientdefindexrender:template=>
为什么4.1%2返回0.0999999999999996?但是4.2%2==0.2。 最佳答案 参见此处:WhatEveryProgrammerShouldKnowAboutFloating-PointArithmetic实数是无限的。计算机使用的位数有限(今天是32位、64位)。因此计算机进行的浮点运算不能代表所有的实数。0.1是这些数字之一。请注意,这不是与Ruby相关的问题,而是与所有编程语言相关的问题,因为它来自计算机表示实数的方式。 关于ruby-为什么4.1%2使用Ruby返
我想在一个没有Sass引擎的类中使用Sass颜色函数。我已经在项目中使用了sassgem,所以我认为搭载会像以下一样简单:classRectangleincludeSass::Script::FunctionsdefcolorSass::Script::Color.new([0x82,0x39,0x06])enddefrender#hamlengineexecutedwithcontextofself#sothatwithintemlateicouldcall#%stop{offset:'0%',stop:{color:lighten(color)}}endend更新:参见上面的#re
如果您尝试在Ruby中的nil对象上调用方法,则会出现NoMethodError异常并显示消息:"undefinedmethod‘...’fornil:NilClass"然而,有一个tryRails中的方法,如果它被发送到一个nil对象,它只返回nil:require'rubygems'require'active_support/all'nil.try(:nonexisting_method)#noNoMethodErrorexceptionanymore那么try如何在内部工作以防止该异常? 最佳答案 像Ruby中的所有其他对象
我遵循了教程http://gettingstartedwithchef.com/,第1章。我的运行list是"run_list":["recipe[apt]","recipe[phpap]"]我的phpapRecipe默认Recipeinclude_recipe"apache2"include_recipe"build-essential"include_recipe"openssl"include_recipe"mysql::client"include_recipe"mysql::server"include_recipe"php"include_recipe"php::modul
关闭。这个问题需要detailsorclarity.它目前不接受答案。想改进这个问题吗?通过editingthispost添加细节并澄清问题.关闭8年前。Improvethisquestion为什么SecureRandom.uuid创建一个唯一的字符串?SecureRandom.uuid#=>"35cb4e30-54e1-49f9-b5ce-4134799eb2c0"SecureRandom.uuid方法创建的字符串从不重复?