Использование маршрутизации колб в функции GCP? - PullRequest
Новая
       34

Использование маршрутизации колб в функции GCP?

0 голосов
/ 26 ноября 2018

Я хочу обслуживать несколько маршрутов из одной облачной функции GCP, используя python.Хотя функции GCP на самом деле используют колбу под колпаком, я не могу понять, как использовать систему маршрутизации колб для обслуживания нескольких маршрутов из одной облачной функции.

Я работал над очень маленьким проектом, поэтому я написал собственный быстрый маршрутизатор, который работает хорошо.Теперь, когда я больше использую функции GCP, я бы хотел либо выяснить, как использовать маршрутизатор Flask, либо уделять больше времени моей ручной версии и, возможно, открытому исходному коду, хотя это может показаться излишним, когда это будет оченьзакройте копию маршрутизации колбы, так что, возможно, было бы лучше добавить ее непосредственно во Flask, если эта функция не существует.

Кто-нибудь имеет какой-либо опыт с этой проблемой?Я предполагаю, что мне не хватает простой функции для использования, которая где-то спрятана во Flask, но если нет, то это кажется довольно большой / распространенной проблемой, хотя я предполагаю, что питон GCP Functions является бета-версией по какой-то причине?

Править: Сокращенный пример моей ручной версии, для которой я хотел бы использовать Flask, если это возможно: 

router = MyRouter()

@router.add('some/path', RouteMethod.GET)
def handle_this(req):
    ...


@router.add('some/other/path', RouteMethod.POST)
def handle_that(req):
    ...


# main entry point for the cloud function
def main(request):
    return router.handle(request)

1 Ответ

0 голосов
/ 08 апреля 2019

У меня работает следующее решение: 

import flask
import werkzeug.datastructures


app = flask.Flask(__name__)


@app.route('some/path')
def handle_this(req):
    ...


@app.route('some/other/path', methods=['POST'])
def handle_that(req):
    ...


def main(request):
    with app.app_context():
        headers = werkzeug.datastructures.Headers()
        for key, value in request.headers.items():
            headers.add(key, value)
        with app.test_request_context(method=request.method, base_url=request.base_url, path=request.path, query_string=request.query_string, headers=headers, data=request.data):
            try:
                rv = app.preprocess_request()
                if rv is None:
                    rv = app.dispatch_request()
            except Exception as e:
                rv = app.handle_user_exception(e)
            response = app.make_response(rv)
            return app.process_response(response)

На основе http://flask.pocoo.org/snippets/131/

...