Stream-Ereignisse vom Server mit WebSockets

Question

Suche Ereignisse mit Web-Sockets vom Server zu streamen, die eine Adresse hat, beginnend mit:

WSS: //example.de/Outbound/OutboundInterface

I bin auf der Suche nach den Optionen, wo ich die Ereignisse vom Server mit Technologien wie Apache Funke, Apache flink streamen kann.

Ich bin unsicher, wie ich die Ereignisse in mein Backend-Projekt für die Universität streamen kann.

Alle Hinweise sind hilfreich, wie ich mit der Problembeschreibung fortfahre.

Answer 1

Eine Möglichkeit, dies zu erreichen, besteht darin, einen kleinen Wrapper zu schreiben, der zwischen der Websocket-Schnittstelle und den Standard-TCP-Sockets (die Apache Spark und Apache Flink beide unterstützen) überbrückt. Hier ist ein Beispiel in Python, die auf die wikipedia websocket Service verbindet und druckt den Strom der Änderungen:

#!/usr/bin/env python 
# -*- coding: utf-8 -*- 

# sudo pip install socketIO_client==0.5.6 
# ./simple.py 2> /dev/null | nc -lk 9999 

import socketIO_client 
import json 

class WikiNamespace(socketIO_client.BaseNamespace): 
    def on_change(self, change): 
     print(json.dumps(change)) 

    def on_connect(self): 
     self.emit('subscribe', 'en.wikipedia.org') 

socketIO = socketIO_client.SocketIO('stream.wikimedia.org', 80) 
socketIO.define(WikiNamespace, '/rc') 

while True: 
    socketIO.wait(10) 

Sie können dann Rohr dies durch nc diese in eine Steckdose zu drehen, dass Flink, kann et al verbinden (hier I habe die Fehler zu/dev/null umgeleitet - Sie lieber in einer Datei setzen könnten):

./simple.py 2> /dev/null | nc -lk 9999