Skip to main content

Client library for socketcluster framework in nodejs

Project description

socketcluster-client-python

Refer examples for more details :

Overview

This client provides following functionality

  • Easy to setup and use
  • Can be used for extensive unit-testing of all server side functions
  • Support for emitting and listening to remote events
  • Automatic reconnection
  • Pub/sub
  • Authentication (JWT)
  • Support for python2.x.x / python3.x.x

To install use

    sudo pip install socketclusterclient

Description

Create instance of Socket class by passing url of socketcluster-server end-point

    //Create a socket instance
    socket = Socketcluster.socket("ws://localhost:8000/socketcluster/") 

Important Note : Default url to socketcluster end-point is always ws://somedomainname.com/socketcluster/.

Registering basic listeners

Different functions are given as an argument to register listeners

        from socketclusterclient import Socketcluster
        import logging

        logging.basicConfig(format='%(levelname)s:%(message)s', level=logging.DEBUG)


        def onconnect(socket):
            logging.info("on connect got called")


        def ondisconnect(socket):
            logging.info("on disconnect got called")


        def onConnectError(socket, error):
            logging.info("On connect error got called")


        def onSetAuthentication(socket, token):
            logging.info("Token received " + token)
            socket.setAuthtoken(token)


        def onAuthentication(socket, isauthenticated):
            logging.info("Authenticated is " + str(isauthenticated))


        if __name__ == "__main__":
            socket = Socketcluster.socket("ws://localhost:8000/socketcluster/")
            socket.setBasicListener(onconnect, ondisconnect, onConnectError)
            socket.setAuthenticationListener(onSetAuthentication, onAuthentication)
            socket.connect()

Connecting to server

  • For connecting to server:
    //This will send websocket handshake request to socketcluster-server
    socket.connect();
  • By default reconnection to server is disabled (since latest release) , to enable it and configure delay for connection
    //This will set automatic-reconnection to server with delay of 2 seconds and repeating it for infinitely
   socket.setdelay(2)
   socket.setreconnection(True)
   socket.connect();
  • By default logging of messages in disabled (since latest release), to enable it
   socket.enablelogger(True)

Emitting and listening to events

Event emitter

  • eventname is name of event and message can be String, boolean, int or JSON-object
    socket.emit(eventname,message);

    # socket.emit("chat", "Hi")
  • To send event with acknowledgement
    socket.emitack("chat", "Hi", ack)  

    def ack(eventname, error, object):
        print "Got ack data " + object + " and error " + error + " and eventname is " + eventname

Event Listener

  • For listening to events :

The object received can be String, Boolean, Long or JSONObject.

     # Receiver code without sending acknowledgement back
     socket.on("ping", message)

     def message(eventname, object):
         print "Got data " + object + " from eventname " + eventname
  • To send acknowledgement back to server
    # Receiver code with ack
    socket.onack("ping", messsageack)

    def messsageack(eventname, object, ackmessage):
        print "Got data " + object + " from eventname " + eventname
        ackmessage("this is error", "this is data")

Implementing Pub-Sub via channels

Creating channel

  • For creating and subscribing to channels:
    # without acknowledgement
    socket.subscribe('yell')

    #with acknowledgement
    socket.subscribeack('yell', suback)

    def suback(channel, error, object):
        if error is '':
            print "Subscribed successfully to channel " + channel
  • For getting list of created channels :
        channels = socket.getsubscribedchannels()

Publishing event on channel

  • For publishing event :
       # without acknowledgement
       socket.publish('yell', 'Hi dudies')

       #with acknowledgement
       socket.publishack('yell', 'Hi dudies', puback)

       def puback(channel, error, object):
           if error is '':
               print "Publish sent successfully to channel " + channel

Listening to channel

  • For listening to channel event :
        socket.onchannel('yell', channelmessage)

        def channelmessage(key, object):
            print "Got data " + object + " from key " + key

Un-subscribing to channel

         # without acknowledgement
         socket.unsubscribe('yell')

         # with acknowledgement
         socket.unsubscribeack('yell', unsuback) 

         def unsuback(channel, error, object):
              if error is '':
                   print "Unsubscribed to channel " + channel 

Disable SSL Certificate Verification

        socket = Socketcluster.socket("wss://localhost:8000/socketcluster/")
        socket.connect(sslopt={"cert_reqs": ssl.CERT_NONE})

HTTP proxy

Support websocket access via http proxy. The proxy server must allow "CONNECT" method to websocket port. Default squid setting is "ALLOWED TO CONNECT ONLY HTTPS PORT".

        socket = Socketcluster.socket("wss://localhost:8000/socketcluster/")
        socket.connect(http_proxy_host="proxy_host_name", http_proxy_port=3128)
  • To have custom settings over internal logger, you can get logger instance and apply necessary settings over it.
        sclogger = socket.getlogger()

Please follow logging tutorial over here : https://docs.python.org/3/howto/logging-cookbook.html

Project details


Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Files for socketclusterclient, version 1.3.6
Filename, size File type Python version Upload date Hashes
Filename, size socketclusterclient-1.3.6-py3-none-any.whl (7.1 kB) File type Wheel Python version py3 Upload date Hashes View
Filename, size socketclusterclient-1.3.6.tar.gz (6.2 kB) File type Source Python version None Upload date Hashes View

Supported by

Pingdom Pingdom Monitoring Google Google Object Storage and Download Analytics Sentry Sentry Error logging AWS AWS Cloud computing DataDog DataDog Monitoring Fastly Fastly CDN DigiCert DigiCert EV certificate StatusPage StatusPage Status page