根据 GAME 上的请求域提供不同的 wsgi 应用程序，线程安全：true

Question

我试图做的是根据请求域加载不同的应用程序（webapp2.WSGIApplication）。 例如 www.domain_1.com 应该加载 app1.main.application 中的应用程序，而 www.domain_2.com 应该加载 app2.main.appplication。
当然，我在同一个 GAE appid 上，并且我使用命名空间来分隔应用程序数据。

这对 'threadsafe:false' 和 runner.py 文件非常有效，其中函数确定要返回哪个应用程序

似乎使用“threadsafe:true”，第一个请求将 wsgiapplication 加载到实例中，并且进一步的请求不再执行“应用程序调度”逻辑，因此请求从错误的应用程序获得响应。

我使用 python2.7 和 webapp2

最好的方法是什么？

编辑：

我的 runner.py 的一个非常简化的版本

def main():
    if domain == 'www.mydomain_1.com':
        from app_1 import application
        namespace = 'app_1'
    elif domain == 'www.domain_2.com':
        from app_2 import application
        namespace = 'app_2'
    namespace_manager.set_namespace(namespace)
    return wsgiref.handlers.CGIHandler().run(application)

if __name__ == '__main__':
    main()

在 app.yaml 中

- url: /.*
  script: app-runner.py

Answer 1

您的运行脚本是 CGI 脚本。未记录启用多线程的 CGI 脚本的完整行为，并且文档的编写方式我猜这不会得到完全支持。相反，文档说，当多线程打开时，您必须直接从app.yaml 引用 WSGI 应用程序对象，使用指向包含该对象的全局变量的模块路径。 （CGI 脚本保留了它们在 Python 2.7 中的旧行为，并关闭了多线程。）

您看到的行为是通过您使用导入来解释的。在单个实例中，每个 import 语句仅在第一次遇到时才起作用。之后，假设模块被导入，import 语句对后续请求没有影响。您可以将这两个值导入到单独的名称中，然后使用适当的值调用 run()。

但是如果你想启用多线程（这是一个好主意），你的调度器应该是一个 WSGI 应用程序本身，存储在一个由app.yaml 引用的全局模块中。我不知道如何将请求从 WSGI 应用程序中分派到另一个 WSGI 应用程序，但这可能是合理的做法。或者，您可以考虑在 WSGI 之上使用或构建一个层来执行此调度。

Answer 2

通过子类化 webapp2.WSGIApplication 并覆盖__call__() 来实现这一点，__call__() 在调度到 RequestHandler 之前被调用。
前缀路由（并删除处理程序初始化中的前缀）和子结构配置以能够使用实例内存。

class CustomWSGIApplication(webapp2.WSGIApplication):

    def __call__(self, environ, start_response):

        routes, settings, ns = get_app(environ)
        namespace_manager.set_namespace(ns)

        environ['PATH_INFO'] = '/%s%s' %(ns, environ.get('PATH_INFO'))

        for route in routes:
            r, h     = route # returns a tuple with mapping and handler
            newroute = ('/%s%s'%(ns, r), h,)
            self.router.add(newroute)


        if settings:
            self.config[ns] = settings

        self.debug  = debug

        with self.request_context_class(self, environ) as (request, response):
            try:
                if request.method not in self.allowed_methods:
                    # 501 Not Implemented.
                    raise exc.HTTPNotImplemented()

                rv = self.router.dispatch(request, response)
                if rv is not None:
                    response = rv
            except Exception, e:
                try:
                    # Try to handle it with a custom error handler.
                    rv = self.handle_exception(request, response, e)
                    if rv is not None:
                        response = rv
                except HTTPException, e:
                    # Use the HTTP exception as response.
                    response = e
                except Exception, e:
                    # Error wasn't handled so we have nothing else to do.
                    response = self._internal_error(e)

            try:
                return response(environ, start_response)
            except Exception, e:
                return self._internal_error(e)(environ, start_response)