Python websocket connect and listen to incoming messages












0















I can't find a very simple example how to do websocket connect in python, and provide some on_message callback that listens to incoming messages.



So the websocket has create_connection method to create a connection, but I don't see where I can pass a callback function that will be called each time the other side send messages to me.



I am creating a simple python websocket proxy/relay, so every time a client is connected to my server, I want to create a connection to another server, and then listen to incoming messages so I can pass them back to the client.










share|improve this question























  • 1. add some code. 2. which lib are you using? 3. the problem is with the client or with the server?

    – Dekel
    Nov 20 '18 at 11:06
















0















I can't find a very simple example how to do websocket connect in python, and provide some on_message callback that listens to incoming messages.



So the websocket has create_connection method to create a connection, but I don't see where I can pass a callback function that will be called each time the other side send messages to me.



I am creating a simple python websocket proxy/relay, so every time a client is connected to my server, I want to create a connection to another server, and then listen to incoming messages so I can pass them back to the client.










share|improve this question























  • 1. add some code. 2. which lib are you using? 3. the problem is with the client or with the server?

    – Dekel
    Nov 20 '18 at 11:06














0












0








0








I can't find a very simple example how to do websocket connect in python, and provide some on_message callback that listens to incoming messages.



So the websocket has create_connection method to create a connection, but I don't see where I can pass a callback function that will be called each time the other side send messages to me.



I am creating a simple python websocket proxy/relay, so every time a client is connected to my server, I want to create a connection to another server, and then listen to incoming messages so I can pass them back to the client.










share|improve this question














I can't find a very simple example how to do websocket connect in python, and provide some on_message callback that listens to incoming messages.



So the websocket has create_connection method to create a connection, but I don't see where I can pass a callback function that will be called each time the other side send messages to me.



I am creating a simple python websocket proxy/relay, so every time a client is connected to my server, I want to create a connection to another server, and then listen to incoming messages so I can pass them back to the client.







python websocket server proxy relay






share|improve this question













share|improve this question











share|improve this question




share|improve this question










asked Nov 20 '18 at 10:31









Nadav BNadav B

540711




540711













  • 1. add some code. 2. which lib are you using? 3. the problem is with the client or with the server?

    – Dekel
    Nov 20 '18 at 11:06



















  • 1. add some code. 2. which lib are you using? 3. the problem is with the client or with the server?

    – Dekel
    Nov 20 '18 at 11:06

















1. add some code. 2. which lib are you using? 3. the problem is with the client or with the server?

– Dekel
Nov 20 '18 at 11:06





1. add some code. 2. which lib are you using? 3. the problem is with the client or with the server?

– Dekel
Nov 20 '18 at 11:06












1 Answer
1






active

oldest

votes


















0














So I managed to do it this way. I hope that's the optimal way to do so.



ws = create_connection(url)
def run(*args):
while True:
try:
message = ws.recv() # This is blocking
# do what I need to do here
except WebSocketClosedError:
break

thread.start_new_thread(run, ())





share|improve this answer























    Your Answer






    StackExchange.ifUsing("editor", function () {
    StackExchange.using("externalEditor", function () {
    StackExchange.using("snippets", function () {
    StackExchange.snippets.init();
    });
    });
    }, "code-snippets");

    StackExchange.ready(function() {
    var channelOptions = {
    tags: "".split(" "),
    id: "1"
    };
    initTagRenderer("".split(" "), "".split(" "), channelOptions);

    StackExchange.using("externalEditor", function() {
    // Have to fire editor after snippets, if snippets enabled
    if (StackExchange.settings.snippets.snippetsEnabled) {
    StackExchange.using("snippets", function() {
    createEditor();
    });
    }
    else {
    createEditor();
    }
    });

    function createEditor() {
    StackExchange.prepareEditor({
    heartbeatType: 'answer',
    autoActivateHeartbeat: false,
    convertImagesToLinks: true,
    noModals: true,
    showLowRepImageUploadWarning: true,
    reputationToPostImages: 10,
    bindNavPrevention: true,
    postfix: "",
    imageUploader: {
    brandingHtml: "Powered by u003ca class="icon-imgur-white" href="https://imgur.com/"u003eu003c/au003e",
    contentPolicyHtml: "User contributions licensed under u003ca href="https://creativecommons.org/licenses/by-sa/3.0/"u003ecc by-sa 3.0 with attribution requiredu003c/au003e u003ca href="https://stackoverflow.com/legal/content-policy"u003e(content policy)u003c/au003e",
    allowUrls: true
    },
    onDemand: true,
    discardSelector: ".discard-answer"
    ,immediatelyShowMarkdownHelp:true
    });


    }
    });














    draft saved

    draft discarded


















    StackExchange.ready(
    function () {
    StackExchange.openid.initPostLogin('.new-post-login', 'https%3a%2f%2fstackoverflow.com%2fquestions%2f53391017%2fpython-websocket-connect-and-listen-to-incoming-messages%23new-answer', 'question_page');
    }
    );

    Post as a guest















    Required, but never shown

























    1 Answer
    1






    active

    oldest

    votes








    1 Answer
    1






    active

    oldest

    votes









    active

    oldest

    votes






    active

    oldest

    votes









    0














    So I managed to do it this way. I hope that's the optimal way to do so.



    ws = create_connection(url)
    def run(*args):
    while True:
    try:
    message = ws.recv() # This is blocking
    # do what I need to do here
    except WebSocketClosedError:
    break

    thread.start_new_thread(run, ())





    share|improve this answer




























      0














      So I managed to do it this way. I hope that's the optimal way to do so.



      ws = create_connection(url)
      def run(*args):
      while True:
      try:
      message = ws.recv() # This is blocking
      # do what I need to do here
      except WebSocketClosedError:
      break

      thread.start_new_thread(run, ())





      share|improve this answer


























        0












        0








        0







        So I managed to do it this way. I hope that's the optimal way to do so.



        ws = create_connection(url)
        def run(*args):
        while True:
        try:
        message = ws.recv() # This is blocking
        # do what I need to do here
        except WebSocketClosedError:
        break

        thread.start_new_thread(run, ())





        share|improve this answer













        So I managed to do it this way. I hope that's the optimal way to do so.



        ws = create_connection(url)
        def run(*args):
        while True:
        try:
        message = ws.recv() # This is blocking
        # do what I need to do here
        except WebSocketClosedError:
        break

        thread.start_new_thread(run, ())






        share|improve this answer












        share|improve this answer



        share|improve this answer










        answered Nov 20 '18 at 11:13









        Nadav BNadav B

        540711




        540711
































            draft saved

            draft discarded




















































            Thanks for contributing an answer to Stack Overflow!


            • Please be sure to answer the question. Provide details and share your research!

            But avoid



            • Asking for help, clarification, or responding to other answers.

            • Making statements based on opinion; back them up with references or personal experience.


            To learn more, see our tips on writing great answers.




            draft saved


            draft discarded














            StackExchange.ready(
            function () {
            StackExchange.openid.initPostLogin('.new-post-login', 'https%3a%2f%2fstackoverflow.com%2fquestions%2f53391017%2fpython-websocket-connect-and-listen-to-incoming-messages%23new-answer', 'question_page');
            }
            );

            Post as a guest















            Required, but never shown





















































            Required, but never shown














            Required, but never shown












            Required, but never shown







            Required, but never shown

































            Required, but never shown














            Required, but never shown












            Required, but never shown







            Required, but never shown







            Popular posts from this blog

            Biblatex bibliography style without URLs when DOI exists (in Overleaf with Zotero bibliography)

            ComboBox Display Member on multiple fields

            Is it possible to collect Nectar points via Trainline?