一种方法是编写一个小 Package 器，在websocket接口和标准tcp套接字（apachespark和apacheflink都支持）之间架起桥梁。下面是一个python示例，它连接到wikipedia websocket服务并打印出编辑流：

# !/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)

然后，您可以通过nc将其传输到flink，etal可以连接到的套接字（这里我将错误重定向到/dev/null—您可以将它们放在一个文件中）：

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