如何用烧瓶扭曲运行？

Question

我希望能够同时在同一个端口的不同目录上运行多个扭曲的代理服务器，我想我可能会使用烧瓶。 所以这是我的代码：

from flask import Flask
from twisted.internet import reactor
from twisted.web import proxy, server

app = Flask(__name__)
@app.route('/example')
def index():
    site = server.Site(proxy.ReverseProxyResource('www.example.com', 80, ''.encode("utf-8")))
    reactor.listenTCP(80, site)
    reactor.run()

app.run(port=80, host='My_IP')

但每当我运行此脚本时，我都会收到内部服务器错误，我假设是因为当在端口 80 上调用 app.run 时，reactor.run 也无法在端口 80 上监听。我想知道是否有某种解决方法，或者我做错了什么。非常感谢任何帮助，谢谢！

Answer 1

您可以使用来自 Twisted 的 WSGIResource 而不是 ReverseProxy。

更新：添加了一个更复杂的示例，该示例在 /my_flask 设置 WSGIResource 并在 /example 设置 ReverseProxy

from flask import Flask
from twisted.internet import reactor
from twisted.web.proxy import ReverseProxyResource
from twisted.web.resource import Resource
from twisted.web.server import Site
from twisted.web.wsgi import WSGIResource

app = Flask(__name__)


@app.route('/example')
def index():
    return 'My Twisted Flask'

flask_site = WSGIResource(reactor, reactor.getThreadPool(), app)

root = Resource()
root.putChild('my_flask', flask_site)

site_example = ReverseProxyResource('www.example.com', 80, '/')
root.putChild('example', site_example)


reactor.listenTCP(8081, Site(root))
reactor.run()

尝试在您的 localhost 中运行上述内容，然后访问 localhost:8081/my_flask/example 或 localhost:8081/example

Answer 2

你应该试试klein。它由大多数twisted 核心开发人员制作和使用。语法很像flask，所以如果你已经有一个工作的flask 应用程序，你就不必重写太多。所以类似下面的应该工作：

from twisted.internet import reactor
from twisted.web import proxy, server
from klein import Klein

app = Klein()

@app.route('/example')
def home(request):
    site = server.Site(proxy.ReverseProxyResource('www.example.com', 80, ''.encode("utf-8")))
    reactor.listenTCP(80, site)

app.run('localhost', 8000)        # start the klein app on port 8000 and reactor event loop

链接

• Klein Docs
• Klein Github

Answer 3

接受的答案不包括如何使用 Flask 扭曲运行，并指向不同的框架。示例的答案也不再有效。

这里有两个不同的例子。第一个与第一个答案相同，但固定在 Python 3 上工作

from flask import Flask
from twisted.internet import reactor
from twisted.web.proxy import ReverseProxyResource
from twisted.web.resource import Resource
from twisted.web.server import Site
from twisted.web.wsgi import WSGIResource

app = Flask(__name__)


@app.route('/example')
def index():
    return 'My Twisted Flask'

flask_site = WSGIResource(reactor, reactor.getThreadPool(), app)

root = Resource()
root.putChild(b'my_flask', flask_site)

site_example = ReverseProxyResource('www.example.com', 80, b'/')
root.putChild(b'example', site_example)


reactor.listenTCP(8081, Site(root))
reactor.run()

对于本例，运行它并打开以下任何一个：

localhost:8081/my_flask/example

localhost:8081/示例

推荐使用另一个示例，因为它设置了两个服务并通过 .tac 文件将它们提供给 twistd。 从这里获取基本代码：https://github.com/pika/pika/blob/master/examples/twisted_service.py

"""Modify the bottom of the file to pick the new MultiService"""
# ... all the code from twisted_service.py goes here.
# Scroll to the bottom of the file and
# remove everything below application = service.Application("pikaapplication")
# You should keep the PikaService, PikaProtocol and PikaFactory
# classes, since we need them for this code:
from pika.connection import ConnectionParameters
from pika.credentials import PlainCredentials
from twisted.application import service, strports
from twisted.internet import reactor
from twisted.web.server import Site
from twisted.web.wsgi import WSGIResource
from flask import Flask

# This IServiceCollection will hold Pika and Flask
flask_pika_multiservice = service.MultiService()

# FLASK SERVICE SETUP
app = Flask("demoapp")
@app.route('/')
def hello_world():
    return 'Hello, World!'

flask_site = Site(WSGIResource(reactor, reactor.getThreadPool(), app))

# New resources can be added, such as WSGI, or proxies by creating
# a root resource in the place of the flask_site, and adding the
# new resources to the root.
# root = Resource()
# root.putChild(b'my_flask_site', flask_site)
# from twisted.web.proxy import ReverseProxyResource
# site_example = ReverseProxyResource('www.example.com', 80, b'/')
# root.putChild(b'example', site_example)

i = strports.service(f"tcp:8088", flask_site)
i.setServiceParent(flask_pika_multiservice)

# PIKA SERVICE SETUP
ps = PikaService(
    ConnectionParameters(
        host="localhost",
        virtual_host="/",
        credentials=PlainCredentials("guest", "guest")))
ps.setServiceParent(flask_pika_multiservice)

# Application setup
application = service.Application('flask_pika')
flask_pika_multiservice.setServiceParent(application)

现在你可以运行它了：

PYTHONPATH=. twistd -ny twisted_service.py

如果您不想从同一路径导入任何内容，则可以跳过 python 路径。 twisted 期望实际安装项目，并且不支持直接从源文件夹运行它们，除非您使用该解决方法。

第二个示例在不同的端口上建立了两个服务。它适用于在同一台扭曲服务器上同时运行的鼠兔和烧瓶。最好的部分是它展示了如何将烧瓶设置为服务，它可以成为 IServiceCollection 的一部分