Hello Everyone, I have been trying to use rasa Custom Connectors mentioned here I m using the name method to connect. My domain.yml file looks like this: utter_greet: - text: default greetings channel: "testchannel" - text: custom greetings My credentials.yml contains the connectors as : connectors.custom_channel.TestChannel: Where custom_channel.py is in inside connectors directory and connectors directory is inside the root directory. directory structure: - data -- nlu.yml -- stories.yml -- rules.yml - actions -- __init__.py -- actions.py - models - connectors -- custom_channel.py - domain.yml - config.yml - credentials.yml - endpoints.yml My custom_channel.py contains following code : from rasa.core.channels.channel import InputChannel from typing import Any, Text, Dict, List class TestChannel(InputChannel): def name() -> Text: """Name of your custom channel.""" return "testchannel" But when I run following command : rasa run -m models --enable-api --cors "*" --credentials credentials.yml --debug i m getting this error : Traceback (most recent call last): File "c:\users\athena\anaconda3\envs\installingrasa\lib\runpy.py", line 193, in _run_module_as_main "__main__", mod_spec) File "c:\users\athena\anaconda3\envs\installingrasa\lib\runpy.py", line 85, in _run_code exec(code, run_globals) File "C:\Users\Athena\anaconda3\envs\installingrasa\Scripts\rasa.exe\__main__.py", line 7, in <module> File "C:\Users\Athena\AppData\Roaming\Python\Python37\site-packages\rasa\__main__.py", line 116, in main cmdline_arguments.func(cmdline_arguments) File "C:\Users\Athena\AppData\Roaming\Python\Python37\site-packages\rasa\cli\run.py", line 90, in run rasa.run(**vars(args)) File "C:\Users\Athena\AppData\Roaming\Python\Python37\site-packages\rasa\run.py", line 57, in run **kwargs, File "C:\Users\Athena\AppData\Roaming\Python\Python37\site-packages\rasa\core\run.py", line 174, in serve_application input_channels = create_http_input_channels(channel, credentials) File "C:\Users\Athena\AppData\Roaming\Python\Python37\site-packages\rasa\core\run.py", line 53, in create_http_input_channels return [_create_single_channel(c, k) for c, k in all_credentials.items()] File "C:\Users\Athena\AppData\Roaming\Python\Python37\site-packages\rasa\core\run.py", line 53, in <listcomp> return [_create_single_channel(c, k) for c, k in all_credentials.items()] File "C:\Users\Athena\AppData\Roaming\Python\Python37\site-packages\rasa\core\run.py", line 65, in _create_single_channel channel File "C:\Users\Athena\AppData\Roaming\Python\Python37\site-packages\rasa\shared\utils\common.py", line 37, in class_from_module_path m = importlib.import_module(module_name) File "c:\users\athena\anaconda3\envs\installingrasa\lib\importlib\__init__.py", line 127, in import_module return _bootstrap._gcd_import(name[level:], package, level) File "<frozen importlib._bootstrap>", line…

Hello Everyone, I figured out a way myself by seeing the code mentioned at rasa rest Here is the code to perform custom connectors completely working with default rest input and custom connections as well Custom Connector code : import asyncio import inspect from sanic import Sanic, Blueprint, response from sanic.request import Request from sanic.response import HTTPResponse from typing import Text, Dict, Any, Optional, Callable, Awaitable, NoReturn from asyncio import Queue, CancelledError import rasa.utils.endpoints from rasa.core.channels.channel import ( InputChannel, CollectingOutputChannel, UserMessage, ) class MyioInput(InputChannel): @classmethod def name(cls) -> Text: return "myio" @staticmethod async def on_message_wrapper( on_new_message: Callable[[UserMessage], Awaitable[Any]], text: Text, queue: Queue, sender_id: Text, input_channel: Text, metadata: Optional[Dict[Text, Any]], ) -> None: collector = QueueOutputChannel(queue) message = UserMessage( text, collector, sender_id, input_channel=input_channel, metadata=metadata ) await on_new_message(message) await queue.put("DONE") async def _extract_sender(self, req: Request) -> Optional[Text]: return req.json.get("sender", None) # noinspection PyMethodMayBeStatic def _extract_message(self, req: Request) -> Optional[Text]: return req.json.get("message", None) def _extract_input_channel(self, req: Request) -> Text: return req.json.get("input_channel") or self.name() def stream_response( self, on_new_message: Callable[[UserMessage], Awaitable[None]], text: Text, sender_id: Text, input_channel: Text, metadata: Optional[Dict[Text, Any]], ) -> Callable[[Any], Awaitable[None]]: async def stream(resp: Any) -> None: q = Queue() task = asyncio.ensure_future( self.on_message_wrapper( on_new_message, text, q, sender_id, input_channel, metadata ) ) while True: result = await q.get() if result == "DONE": break else: await resp.write(json.dumps(result) + "\n") await task return stream def blueprint( self, on_new_message: Callable[[UserMessage], Awaitable[None]] ) -> Blueprint: custom_webhook = Blueprint( "custom_webhook_{}".format(type(self).__name__), inspect.getmodule(self).__name__, ) # noinspection PyUnusedLocal @custom_webhook.route("/", methods=["GET"]) async def health(request: Request) -> HTTPResponse: return response.json({"status": "ok"}) @custom_webhook.route("/webhook", methods=["POST"]) async def receive(request: Request)…

Hello @erohmensing can anyone help me out here. please.

[image] athenasaurav: NameError: name 'Text' is not defined Looking at this error makes me think that your issue is related to an import missing. Are you 100% sure it is imported in MyIO.py? You’re looking for this line: from typing import Text

Hello @koaning , i did try this also and I got this error Traceback (most recent call last): File "c:\users\athena\anaconda3\envs\installingrasa\lib\runpy.py", line 193, in _run_module_as_main 2021-03-25 02:56:36 "__main__", mod_spec) DEBUG File "c:\users\athena\anaconda3\envs\installingrasa\lib\runpy.py", line 85, in _run_code urllib3.connectionpool - Starting new HTTPS connection (1): o251570.ingest.sentry.io:443 exec(code, run_globals) File "C:\Users\Athena\anaconda3\envs\installingrasa\Scripts\rasa.exe\__main__.py", line 7, in <module> File "C:\Users\Athena\AppData\Roaming\Python\Python37\site-packages\rasa\__main__.py", line 116, in main cmdline_arguments.func(cmdline_arguments) File "C:\Users\Athena\AppData\Roaming\Python\Python37\site-packages\rasa\cli\run.py", line 90, in run rasa.run(**vars(args)) File "C:\Users\Athena\AppData\Roaming\Python\Python37\site-packages\rasa\run.py", line 57, in run **kwargs, File "C:\Users\Athena\AppData\Roaming\Python\Python37\site-packages\rasa\core\run.py", line 187, in serve_application conversation_id=conversation_id, File "C:\Users\Athena\AppData\Roaming\Python\Python37\site-packages\rasa\core\run.py", line 116, in configure_app channels.channel.register(input_channels, app, route=route) File "C:\Users\Athena\AppData\Roaming\Python\Python37\site-packages\rasa\core\channels\channel.py", line 89, in register p = urljoin(route, channel.url_prefix()) File "C:\Users\Athena\AppData\Roaming\Python\Python37\site-packages\rasa\core\channels\channel.py", line 108, in url_prefix return self.name() TypeError: name() takes 0 positional arguments but 1 was given 2021-03-25 02:56:37 DEBUG urllib3.connectionpool - https://o251570.ingest.sentry.io:443 "POST /api/2801673/store/ HTTP/1.1" 200 41

The solution offered by @athenasaurav seems to work great! Is it possible to update the docs, since the code in the docs throws the same error shown above: [image] athenasaurav: TypeError: name() takes 0 positional arguments but 1 was given

I was putting messege from custom channel which is whatsapp I got this exception How can handle this exception: 2021-04-06 08:52:35 ERROR addons.custom_channel - An exception occured while handling user message ‘{‘text’: ‘Hi’, ‘media’: {‘mediaUri’: ‘’, ‘contentType’: ‘’, ‘title’: ‘’}, ‘custom’: {}}’. Traceback (most recent call last): File “C:\Users\tendaji-adm\Desktop\Chatbot\addons\custom_channel.py”, line 126, in receive metadata=metadata, File “c:\users\tendaji-adm\appdata\local\programs\python\python37\lib\site-packages\rasa\core\channels\channel.py”, line 58, in init self.text = text.strip() if text else text AttributeError: ‘dict’ object has no attribute ‘strip’

Hello @shubhampawar18 can you please repost the error message by formatting it correctly. Also have you written any custom connector for whatsapp, or you are using default twillio integration?

No I am not using Twilio . Yes write custom connector for WhatsApp. I got exception for message coming from WhatsApp. 2021-04-06 11:02:51 ERROR addons.custom_channel - An exception occured while handling user message ‘{‘text’: ‘Hi’, ‘media’: {‘mediaUri’: ‘’, ‘contentType’: ‘’, ‘title’: ‘’}, ‘custom’: {}}’. Traceback (most recent call last): File “C:\Users\tendaji-adm\Desktop\Chatbot\addons\custom_channel.py”, line 126, in receive metadata=metadata, File “c:\users\tendaji-adm\appdata\local\programs\python\python37\lib\site-packages\rasa\core\channels\channel.py”, line 58, in init self.text = text.strip() if text else text AttributeError: ‘dict’ object has no attribute ‘strip’

Please share your code for custom connector for whatsapp. I dont think this is the code mentioned here

This is my code for custom channel :- import asyncio import inspect import json import logging from asyncio import Queue, CancelledError from sanic import Sanic, Blueprint, response from sanic.request import Request from sanic.response import HTTPResponse from typing import Text, Dict, Any, Optional, Callable, Awaitable, NoReturn import rasa.utils.endpoints from rasa.core.channels.channel import ( InputChannel, CollectingOutputChannel, UserMessage, ) logger = logging.getLogger(name) class WhatsappInput(InputChannel): “”“A custom http input channel. This implementation is the basis for a custom implementation of a chat frontend. You can customize this to send messages to Rasa and retrieve responses from the assistant.”"" @classmethod def name(cls) -> Text: return "whatsapp" @staticmethod async def on_message_wrapper( on_new_message: Callable[[UserMessage], Awaitable[Any]], text: Text, queue: Queue, sender_id: Text, input_channel: Text, metadata: Optional[Dict[Text, Any]], ) -> None: collector = QueueOutputChannel(queue) message = UserMessage( text, collector, sender_id, input_channel=input_channel, metadata=metadata ) await on_new_message(message) await queue.put("DONE") async def _extract_sender(self, req: Request) -> Optional[Text]: return req.json.get("sender", None) # noinspection PyMethodMayBeStatic def _extract_message(self, req: Request) -> Optional[Text]: return req.json.get("message", None) def _extract_input_channel(self, req: Request) -> Text: return req.json.get("input_channel") or self.name() def stream_response( self, on_new_message: Callable[[UserMessage], Awaitable[None]], text: Text, sender_id: Text, input_channel: Text, metadata: Optional[Dict[Text, Any]], ) -> Callable[[Any], Awaitable[None]]: async def stream(resp: Any) -> None: q = Queue() task = asyncio.ensure_future( self.on_message_wrapper( on_new_message, text, q, sender_id, input_channel, metadata ) ) while True: result = await q.get() if result == "DONE": break else: await resp.write(json.dumps(result) + "\n") await task return stream def blueprint( self, on_new_message: Callable[[UserMessage], Awaitable[None]] ) -> Blueprint: custom_webhook = Blueprint( "custom_webhook_{}".format(type(self).__name__), inspect.getmodule(self).__name__, ) # noinspection PyUnusedLocal @custom_webhook.route("/", methods=["GET"]) async def health(request: Request) -> HTTPResponse: return response.json({"status": "ok"}) @custom_webhook.route("/webhook", methods=["POST"]) async def receive(request: Request) -> HTTPResponse: sender_id = await self._extract_sender(request) text = self._extract_message(request) should_use_stream = rasa.utils.endpoints.bool_ar…

[Screenshot 2021-04-07 093241] This is error while message passing.

RASA Custom Connector keep giving custom response

Rasa Open Source

hemanthyernagula (Hemanth) September 11, 2021, 6:44pm 15

This is because you did not pass self keyword for def name() method it is supposed to be def name(self) after changing to this it worked for me

Topic		Replies	Views
[Solved] How to implement our own custom connector for the custom UI Rasa Open Source	40	10877	January 4, 2022
Rasa X - How to setup Custom Connector using Helm? [Deprecated] Rasa X Community Edition	2	702	December 3, 2020
Custom connector Issue Rasa Open Source	0	141	January 13, 2024
Looking for help in implementing Custom Channel Getting Started with Rasa	7	666	August 10, 2022
Custom connector channel problem Rasa Open Source	2	741	June 13, 2023

RASA Custom Connector keep giving custom response

Related topics