Rasa X - коннектор Google Assistant не получает сообщений от Rasa - PullRequest
Новая
       48

Rasa X - коннектор Google Assistant не получает сообщений от Rasa

0 голосов
/ 29 мая 2019

Я создаю соединитель для Rasa X (rasa 1.0) для работы с Google Assistant в качестве внешнего интерфейса. До выхода 1.0 этот урок: https://medium.com/rasa-blog/going-beyond-hey-google-building-a-rasa-powered-google-assistant-5ff916409a25 работал очень хорошо. Однако когда я попытался запустить Rasa X в той же структуре, между моим старым соединителем на основе Flask и агентом Rasa, запускающим проект, возникли несовместимости.

В новой версии rasa.core.agent.handle_channels([input_channel], http_port=xxxx) вместо этого использует Sanic, что, похоже, несовместимо с моим старым методом.

Я попытался преобразовать старый соединитель Flask в Sanic (никогда ранее не использовал его), и я использовал Postman для проверки работоспособности маршрута. Я также получаю полезную нагрузку от помощника. Однако, когда я пересылаю это агенту Расы, я ничего не получаю взамен.

  • Это новый разъем Sanic: 
class GoogleAssistant(InputChannel):

    @classmethod
    def name(cls):
        return "google_assistant"

    def blueprint(self, on_new_message):
        # this is a Sanic Blueprint
        google_webhook = sBlueprint("google_webhook")

        @google_webhook.route("/", methods=['GET'])
        def health(request):
            return response.json({"status": "ok"})

        @google_webhook.route("/webhook", methods=["POST"])
        def receive(request):
            #payload = json.loads(request)
            payload = request.json
            sender_id = payload["user"]['userId']
            intent = payload['inputs'][0]['intent']             
            text = payload['inputs'][0]['rawInputs'][0]['query']

            try:
                if intent == "actions.intent.MAIN":
                    message = "<speak>Hello! <break time=\"1\"/> Welcome to the Rasa-powered Google Assistant skill. You can start by saying hi."
                else:
                    # Here seems to be the issue. responses is always empty
                    out = CollectingOutputChannel()
                    on_new_message(UserMessage(text,out,sender_id))
                    responses = [m["text"] for m in out.messages]
                    message = responses[0]
            except LookupError as e:
                message = "RASA_NO_REPLY"
                print(e)

            r = json.dumps("some-response-json")
            return HTTPResponse(body=r, content_type="application/json")

        return google_webhook
  • А вот скрипт запуска проекта: 
action_endpoint = EndpointConfig(url="http://localhost:5055/webhook")
nlu_interpreter = RasaNLUInterpreter('path-to-model')
agent = Agent.load('path-to-model-2', interpreter = nlu_interpreter, action_endpoint=action_endpoint)

input_channel = GoogleAssistant()
agent.handle_channels([input_channel], http_port=5010)

Я ожидаю, что выводом будет текст, выбранный агентом Rasa в качестве ответа "Это ответ", но я ничего не получаю (список пуст).

EDIT

Я определил def receive(request): как async def receive(request): и изменил on_new_message(UserMessage(text,out,sender_id)) на await on_new_message(UserMessage(text,out,sender_id)). Кроме того, скрипт запуска проекта теперь: 

loop = asyncio.get_event_loop()  

action_endpoint = EndpointConfig(url="http://localhost:5055/webhook")
nlu_interpreter = RasaNLUInterpreter('path')
agent = Agent.load('path2', interpreter = nlu_interpreter, action_endpoint=action_endpoint)
input_channel = GoogleAssistant()

loop.run_until_complete(agent.handle_channels([input_channel], http_port=5010))
loop.close()

К сожалению ничего не изменилось , все еще не получая никакого ответа от Расы на выходном канале.

1 Ответ

0 голосов
/ 29 мая 2019

В связи с введением асинхронного сервера Sanic, следует ожидать on_new_message.Попробуйте изменить определение функции на 

async def receive(request):

, а на остальное - 

out = CollectingOutputChannel()
await on_new_message(UserMessage(query, output_channel, user_id))
m = [m['text'] for m in out.messages]
message = responses[0]
...