Между Намеко и Флягой нет маршрута - PullRequest
0 голосов
/ 03 июня 2018

если вы видели мой последний вопрос час назад или почти)!

Мне удалось решить много проблем, но я застрял с одной и не могу понять, почему она у меня есть.Я предпочитаю создавать новую тему, потому что ошибка не та, и для будущих читателей она будет понятнее.

Моя цель, как я уже говорил в предыдущем вопросе, - иметь микросервисы с Python и Nameko.отправка результатов и получение информации и запросов от веб-приложения Flask (и в будущем от многих веб-приложений Flask).Но теперь у меня проблема с маршрутом - 312.

Код из моего приложения Nameko:

# -*-coding:utf-8 -*

# namekotesting.py

from nameko.rpc import rpc

class firstService:
        name = "First microservice"
        result = "";

        @rpc
        def mymethode(self, test):
                result = test
                return result

Код из приложения Flask:

#! /usr/bin/python
# -*- coding:utf-8 -*-

from flask import Flask, request
from flasgger import Swagger
from nameko.standalone.rpc import ClusterRpcProxy

app = Flask(__name__)
Swagger(app)
CONFIG = {'AMQP_URI': "amqp://guest:guest@<myipserverhere>:5672"}

@app.route('/', methods=['GET', 'POST'])

def mymethode():
        with ClusterRpcProxy(CONFIG) as rpc:
                littletest = rpc.firstService.mymethode("hello")

def index():
        return littletest

if __name__ == '__main__':
    app.run(host='0.0.0.0', debug=True, port=5000)

А теперьошибка:

 * Serving Flask app "flasktest" (lazy loading)
 * Environment: production
   WARNING: Do not use the development server in a production environment.
   Use a production WSGI server instead.
 * Debug mode: on
 * Running on http://0.0.0.0:5000/ (Press CTRL+C to quit)
 * Restarting with stat
 * Debugger is active!
 * Debugger PIN: 126-185-375
[03/Jun/2018 21:04:27] "GET / HTTP/1.1" 500 -
Traceback (most recent call last):
  File "/usr/local/lib/python2.7/dist-packages/flask/app.py", line 2309, in __call__
    return self.wsgi_app(environ, start_response)
  File "/usr/local/lib/python2.7/dist-packages/flask/app.py", line 2295, in wsgi_app
    response = self.handle_exception(e)
  File "/usr/local/lib/python2.7/dist-packages/flask/app.py", line 1741, in handle_exception
    reraise(exc_type, exc_value, tb)
  File "/usr/local/lib/python2.7/dist-packages/flask/app.py", line 2292, in wsgi_app
    response = self.full_dispatch_request()
  File "/usr/local/lib/python2.7/dist-packages/flask/app.py", line 1815, in full_dispatch_request
    rv = self.handle_user_exception(e)
  File "/usr/local/lib/python2.7/dist-packages/flask/app.py", line 1718, in handle_user_exception
    reraise(exc_type, exc_value, tb)
  File "/usr/local/lib/python2.7/dist-packages/flask/app.py", line 1813, in full_dispatch_request
    rv = self.dispatch_request()
  File "/usr/local/lib/python2.7/dist-packages/flask/app.py", line 1799, in dispatch_request
    return self.view_functions[rule.endpoint](**req.view_args)
  File "/home/oyo/flasktest/flasktest.py", line 16, in mamethode
    petittest = rpc.premierService.mamethode("voici")
  File "/usr/local/lib/python2.7/dist-packages/nameko/rpc.py", line 368, in __call__
    reply = self._call(*args, **kwargs)
  File "/usr/local/lib/python2.7/dist-packages/nameko/rpc.py", line 437, in _call
    extra_headers=extra_headers
  File "/usr/local/lib/python2.7/dist-packages/nameko/amqp/publish.py", line 189, in publish
    **publish_kwargs
  File "/usr/local/lib/python2.7/dist-packages/kombu/messaging.py", line 181, in publish
    exchange_name, declare,
  File "/usr/local/lib/python2.7/dist-packages/kombu/connection.py", line 494, in _ensured
    return fun(*args, **kwargs)
  File "/usr/local/lib/python2.7/dist-packages/kombu/messaging.py", line 203, in _publish
    mandatory=mandatory, immediate=immediate,
  File "/usr/local/lib/python2.7/dist-packages/amqp/channel.py", line 1743, in basic_publish_confirm
    self.wait(spec.Basic.Ack)
  File "/usr/local/lib/python2.7/dist-packages/amqp/abstract_channel.py", line 79, in wait
    self.connection.drain_events(timeout=timeout)
  File "/usr/local/lib/python2.7/dist-packages/amqp/connection.py", line 491, in drain_events
    while not self.blocking_read(timeout):
  File "/usr/local/lib/python2.7/dist-packages/amqp/connection.py", line 497, in blocking_read
    return self.on_inbound_frame(frame)
  File "/usr/local/lib/python2.7/dist-packages/amqp/method_framing.py", line 77, in on_frame
    callback(channel, msg.frame_method, msg.frame_args, msg)
  File "/usr/local/lib/python2.7/dist-packages/amqp/connection.py", line 501, in on_inbound_method
    method_sig, payload, content,
  File "/usr/local/lib/python2.7/dist-packages/amqp/abstract_channel.py", line 128, in dispatch_method
    listener(*args)
  File "/usr/local/lib/python2.7/dist-packages/amqp/channel.py", line 1960, in _on_basic_return
    raise exc
ChannelError: Basic.return: (312) NO_ROUTE

Я останусь в этой теме сейчас, чтобы закончить свои тесты (если у меня есть другая проблема, которую я не могу решить).После этого, я думаю, я смогу сделать мои рамки благодаря этому.Любой совет, советы или помощь для этого, на данный момент?

Спасибо заранее.

Ответы [ 2 ]

0 голосов
/ 04 июня 2018

Атрибут name в классе обслуживания определяет способ обращения к услуге.

class firstService:
    name = "first"

    @rpc
    def method(self):
        pass

То есть

>>> rpc.firstService.method()  # won't work
>>> rpc.first.method()         # will work

Также похоже, что вы используете слишком современныйверсия py-amqp.Вы обновили его после установки Nameko?Это должно быть v1.4.9.В этой версии вы получите более полезную ошибку «Неизвестная служба».

0 голосов
/ 03 июня 2018

RabbitMQ отправляет обратно с «basic.return», когда «обязательное» сообщение не может быть доставлено в какую-либо очередь.

Вы можете запустить это?

rabbitmq-plugins enable rabbitmq_management

, а затем откройте

http://server-name:15672/ #server-name i think is `localhost` 

, войдя в систему с помощью guest и паролем guest документы

, и там будетвся информация о queues channels exchanges и т. д.

есть ли декларация queue, куда вы хотите отправить сообщение?

, если нет queue, создайте его

...