pythonautobahncrossbar

subscribe to a topic in python on crossbar autobahn


I am a noob in crossbar. I am trying to subscribe to a topic using autobahn and crossbar in python.

The crossbar url is "wss://******.******.org/ws/" and the topic is c******d.

There are no signalisation topics, every calls are going to this topic c******d.

I found some pieces of code there https://autobahn.readthedocs.io/en/latest/ and tried to adapt it.

from autobahn.twisted.component import Component
from twisted.internet.defer import inlineCallbacks
from autobahn.twisted.component import Component
from autobahn.twisted.component import run

#component with my crossbar url :

component = Component(
     transports=u"wss://******.******.org/ws/",       
     realm=u"realm1",
 )

@component.on_join
@inlineCallbacks
def joined(session,details):
    print("session ready")

    def oncounter(count):
        print("event received: {0}", count)

    try:
        yield session.subscribe(oncounter, u'c******d') #here my topic
        print("subscribed to topic")
    except Exception as e:
        print("could not subscribe to topic: {0}".format(e))

if __name__ == "__main__":
     run([component]) 

I am getting this error. It seems like nothing is working properly.

2019-10-25T14:38:07+0200 SSL error: certificate verify failed (in tls_process_server_certificate)
2019-10-25T14:38:07+0200 TLS failure: certificate verify failed
2019-10-25T14:38:07+0200 Stopping factory <autobahn.twisted.websocket.WampWebSocketClientFactory object at 0x000002B693A58>
2019-10-25T14:38:09+0200 connecting once using transport type "websocket" over endpoint "tcp"
2019-10-25T14:38:09+0200 Starting factory <autobahn.twisted.websocket.WampWebSocketClientFactory object at 0x000002B693A58>
2019-10-25T14:38:09+0200 SSL error: certificate verify failed (in tls_process_server_certificate)
2019-10-25T14:38:09+0200 TLS failure: certificate verify failed
2019-10-25T14:38:09+0200 Stopping factory <autobahn.twisted.websocket.WampWebSocketClientFactory object at 0x000002B693A58>
2019-10-25T14:38:12+0200 connecting once using transport type "websocket" over endpoint "tcp"
2019-10-25T14:38:12+0200 Starting factory <autobahn.twisted.websocket.WampWebSocketClientFactory object at 0x000002B693A58>

As mentioned I am new to this, so any insights on the above would be greatly appreciated!


Solution

  • I think that what you are trying to do is :

    import sys 
    import asyncio
    from autobahn.asyncio.wamp import ApplicationSession, ApplicationRunner
    import autobahn.wamp
    
    
    class Component(ApplicationSession):
    
        """
        An application component that subscribe to a topic
        and print messages
    
        """
        async def onJoin(self, details):
    
            def onmessage(*args, **kwargs):
                print ("message received kwargs= "+str(kwargs))
    
            await self.subscribe(onmessage, "c******d")
    
        def onDisconnect(self):
    
            asyncio.get_event_loop().stop()
    
    if __name__ == '__main__':
    
            url = u"wss://************.org/ws/"
            realm = u"realm1"
            runner = ApplicationRunner(url, realm)
            runner.run(Component,'debug')