问题标签 [wamp-protocol]

我正在尝试同时autobahn.asyncio.wamp.ApplicationSession在 python 中运行两个 s。以前，我按照本文的答案中的建议使用了高速公路库的修改来做到这一点。我现在需要更专业的解决方案。

在谷歌上搜索了一段时间后，这篇文章看起来很有希望，但使用的是twisted库，而不是asyncio. 我无法为图书馆的asyncio分支找到类似的解决方案autobahn，因为它似乎没有使用Reactors.

我遇到的主要问题ApplicationRunner.run()是阻塞（这就是我之前将它外包给线程的原因），所以我不能只ApplicationRunner在它之后运行一秒钟。

我确实需要同时访问 2 个 websocket 通道，而我似乎无法使用单个ApplicationSession.

到目前为止我的代码：

我对autobahn图书馆的了解有限，恐怕文档并没有太大改善我的情况。我在这里忽略了什么吗？一个函数，一个参数，它可以让我组合我的组件或同时运行它们？

也许与此处提供的类似解决方案实现了替代方案ApplicationRunner？

相关话题

以扭曲的方式运行两个 ApplicationSession

在线程中运行 Autobahn ApplicationRunner

Autobahn.wamp.ApplicationSession 源

Autobahn.wamp.Applicationrunner 源代码

根据要求，来自@stovfl 的回溯使用multithreading代码回答：

Visual Studio 2012：Microsoft 网站上不再提供 VC 11 vcredist_x64/86.exe，但我需要它来运行 WAMP。

这是应该下载的链接：http: //www.microsoft.com/en-us/download/details.aspx ?id= 30679 我怎样才能得到这些文件？有第三方下载吗？

在这里使用这个答案，我正在尝试使用 jawampa 连接到 Poloniex 公共推送 API，但 jawampa 不会连接。我的代码是：

输出是：

类 ws.wamp.jawampa.WampClient$DisconnectedState

好的

类 ws.wamp.jawampa.WampClient$ConnectingState

然后什么也没有发生。我让它打印出 WampClient 类名字符串，以帮助了解发生了什么。我究竟做错了什么？

我什至复制了我在这里找到的另一个实现，但它仍然不起作用。这个人的实现给出了以下输出：

会话状态更改为断开连接

会话状态更改为正在连接

...但是它就像我上面的代码一样挂起。

我在 poloniex.com 上制作用于剥头皮的软件为此，我需要了解有关订单簿的最新信息。 API DOCUMENTATION谈到了推送 api。据我了解，它是这样工作的：

1. 使用 returnOrderBook（公共方法 API）获取快照
2. 从响应中获取序列号（seq key）
3. 使用快照中的序列号订阅推送 api

4. 接收新数据并对快照数据进行更正。

   /li>

这是脚本日志：

如您所见，快照中的序列号为：106470819 但从推送 API 接收的序列号与快照序列号无关：106307669、106307670、...

为了使用 WAMP，我使用 Thruway。我阅读了文档和谷歌搜索，但找不到解决方案。

PS 现在我认为我不明白 poloniex api 是如何工作的-( PPS 对不起我丑陋的英语。这不是我的母语

我尝试使用 python 连接到 poloniex 中的 Push API，并按照此处的答案说明进行操作：

如何使用 python 库连接到 poloniex.com websocket api

但是我不断收到此错误：

2017-06-25T04:07:04 放弃与对等 tcp:104.20.13.48:443 的连接，中止 = True：WebSocket 打开握手超时（对等未及时完成打开握手）

有人知道这里发生了什么吗？我无法从在线文档中弄清楚。谢谢！

我正在使用 C# WAMP 客户端连接到 Poloniex 交易所以获取实时市场数据。根据交易所提供的文档，为了创建实时订单簿，我们必须首先通过 REST 获取订单簿的快照他们提供的 api 并从中提取序列号，然后连接到 WAMP 服务器以获取流数据并更新订单簿快照。

我在更新通过 REST api 收到的快照订单簿时遇到问题，因为我通过 REST api 收到的序列号比通过 WAMP 收到的序列号早近 400k 记录。

有没有其他方法可以让我从 POloniex 交易所获取实时流数据，或者我错过了什么？

我正在尝试将aiohttpWeb 服务器集成到 Crossbar+Autobahn 系统架构中。

更详细地说，当aiohttp服务器接收到某个 API 调用时，它必须向 Crossbar 路由器发布消息。我在官方 repos 上看到过这个例子，但我不知道如何将它集成到我的应用程序中。

理想情况下，我希望能够做到这一点

其中selfil 的一个实例SampleTaskController(object)定义了 Web 服务器的所有路由处理程序。

请注意，我使用的是一个，zmq.asyncio.ZMQEventLoop因为服务器也在侦听在方法zmq内部配置的套接字controller.on_startup。

我没有使用高速公路，而是尝试使用 Crossbar 将消息发布到 Crossbarwampy并且它可以工作，但是高速公路订阅者无法正确解析消息。

-

使用此配置，订阅者会收到已发布的消息，但在解析时会出现异常。

我正在尝试使用 crossbar/autobahn 的 RPC 通过 websockets 传输大数据。我的设置如下：

• 蟒蛇 2.7
• 交叉开关路由器（版本 17.8.1.post1）
• 将尝试将大熊猫 DataFrame 作为 json 字符串发送的后端
• 想要接收此字符串的前端

本质上，我的前端正在尝试调用一个返回大字符串的函数。

我得到这个错误：

似乎 crossbar 正在将我踢出去，因为我的客户端会话在他看来已死，但我认为高速公路会将我的数据分块，并且该调用不会阻塞客户端反应器。

我在交叉开关配置中启用了一些东西来改进 websocket 处理；多亏了这一点，我能够传输大量数据，但最终我会遇到限制（配置文件主要从 sam & max 复制和粘贴）。

任何想法，需要，我做错的事情？

谢谢，

客户端代码：

后端代码

配置

我想构建一个 WAMP（Web 应用程序消息传递协议）客户端来订阅 poloniex 的代码。poloniex 的 API 文档中有一些有用的信息，如下所示：

但是他们没有说如何使用python订阅它。然后我尝试在google中搜索，我没有任何帮助。

谁能告诉我如何构建一个 WAMP 客户端来订阅 poloniex 的代码？谢谢！

----------- 更新 -------------- 我发现代码遵循我想要的样子：

但它显示以下错误：

我发现了一些线索，似乎某些模块只能在 python3 中正常工作。多么失望！

Tableau 有多个数据连接器。这些似乎都使用了请求/响应机制来拉取/轮询数据更新。

我有一个使用 crossbar.io（路由器）和 autobahn-python（wamp 生产者）谈论 WAMP（Web 应用程序消息传递协议）的数据服务。是否有可用于使用此服务的 Tableau 连接器？或者更一般地说，Tableau 是否具有可用于通过 Web 套接字进行通信的连接器？