我正在使用Kucoin (加密交换)发送order_book更新的流式应用程序接口，我正在尝试使用消息处理器方法处理入站order_book websocket消息，然后只在所有消息处理完毕后返回，但我认为我设计的模式是错误的，或者误解了异步和websocket。if websocket.index(message) + 1 == len(websocket): # check if this is
浏览 35提问于2021-07-30得票数 0
回答已采纳
在本例中，我尝试使用listen/，并在websocket中实现它。我还使用了很多常见的http端点以及websocket端点。我希望在FastAPI应用程序开始时运行一个永久的后台异步函数，然后将消息发送到所有的websocket客户机/连接。因此，当我使用uvicorn main:app时，它不仅应该运行FastAPI应用程序，还应该运行我的后台函数postgres_listen()，后者在向数据库中的表中添
浏览 7提问于2022-06-09得票数 1
回答已采纳
2回答
我遇到了一些问题，当我启动我的程序时，我运行WindowForm1，然后用户必须输入密码和用户名，如果它是正确的，那么它退出form1并运行form2。如果用户输入错误的密码或用户名，那么他有机会重新输入，或者他可以关闭程序与“红色X”-这是正常的。但是，当密码和用户名正确时，当他按下“关闭”时，Form2正在运行，应用程序仍然在后台运行。当他在Window Form 2上按close时，您能告诉我如何关闭此应用程序吗？
浏览 1提问于2016-07-12得票数 0
1回答
我正在尝试实现到服务器的WebSocket连接(Python <=> Django应用程序)import as
浏览 30提问于2022-04-14得票数 0
回答已采纳
它管理完整性(不丢失数据)和缓冲的命令，以确保源源不断的G代码命令提供给TinyG，以确保顺利的数控运动控制。
我知道服务器在SPJS端看到连接尝试和失败475: Err unmarshalling TCP inbound me
浏览 8提问于2022-10-25得票数 0
我想使用nginx (谢天谢地，它刚刚开始支持websockets)和uwsgi用于web服务器，并且我使用zeromq在系统中传递消息。理想情况下，解决方案可以用Python编写，但我也可以使用Nodejs，甚至是Go解决方案。
当处理完成后，工作人员发送一个“已完成的处理！”通过zeromq向websocket进程发送消息，web
浏览 6提问于2013-03-08得票数 3
回答已采纳
我正在尝试集成websocket聊天使用ERlang，牛仔，Websocket和gen_bunny。在将它们集成在一起时，我能够将消息从浏览器传递给牛仔，并将其传递给RabbitMQ，然后再从RabbitMQ我甚至可以将消息回复给发送它的用户。但是，我希望将消息广播给所有已连接的用户。
根据我的理解，Erlang将为每个用户创建一个单独的进程。
浏览 1提问于2013-05-01得票数 4
回答已采纳
我正在运行一个autobahn/扭曲服务器，而且我在向客户发送消息方面遇到了问题。它似乎只在客户端发送消息时才向客户端发送消息。由于某种原因，如果我想向连接的客户端强制发送消息，该消息将被卡在队列中，直到任何客户端向我发送消息为止。此时，所有排队的消息都会发送到所有客户端。我能够使用python客户端和javascript客户端在这个python &#x
浏览 8提问于2020-12-14得票数 1
回答已采纳
我的意思是我能从使用async for中得到什么。这是我用async for写的代码，AIter(10)可以用get_range()代替。 for i in range(10): awaitasyncio.sleep(1) yield i
浏览 0提问于2019-05-16得票数 44
回答已采纳
1回答
我遇到了大麻烦，我不能理解为什么这个东西不能工作。我需要为数组的每个值发出一个API请求，如果我查看我的控制台javascript，请求会被处理，但我需要request.The内部的纬度和经度值。问题是，在API请求之外，我有4个值(每个数组元素有2个经度和2个经度)，而在API请求内部，我只找到最后两个经度和经度，为什么?这似乎真的没有意义，我不知道问题在哪里be.Here是代码。 { "lat":"45.46" , "lng":"9.
浏览 0提问于2015-05-29得票数 1
srv.wait_closed()) loop.close()现在我想使用下面描述的结构(节点服务器= python更具体地说，使用机制与一起读取和写入websocket连接和中的Redis。既然我已经在使用，那么我应该采取以下两种方法中的哪一种：
就像在“经典”web应用程序中一样，有一个控制
浏览 6提问于2015-07-28得票数 18
回答已采纳
1回答
目前，我正在尝试以消息到达的相同顺序处理消息列表。为了处理它，我使用python asyncio将每条消息作为couroutine/task执行。因此，我将相应地创建couroutine/task，并将其添加到asyncio run loop循环中。但在角点情况下，协程中可能会出现一些异常。在异常时，我计划重试这些消息或以不同的方式处理它。from asyncio import get_event_loop, sl
浏览 2提问于2021-03-02得票数 0
1回答
此HTTP服务器需要使用websocket连接将工作委托给第三方服务器(出于性能原因)。async def send(websocket, payload):
async def re
浏览 1提问于2021-10-05得票数 0
回答已采纳
在each()回调中，我使用Meteor集合对一个不相关集合进行读取：当执行读取操作时，该执行路径暂停，下一条记录开始处理。这种情况一直在发生。所以看起来findOne()在each()回调中不再是同步的了？
有人知道我如何安全地混合原生Mongo和Meteor收藏吗？在处理大量记录时，我尽量避免Meteor集合的开销。
浏览 1提问于2014-08-06得票数 1
我正在编写一个Python程序，它可以实现一些交易自动化。我使用的API来自德里比特，它的首选传输机制是Websocket。我是Python的websockets和asyncio模块的完全新手。下面是我首先为验证我的客户端而编写的代码，然后发送一条单独的私有消息，从帐户中获取订单位置，只使用函数而不使用类：import websockets response = await get_positio
浏览 6提问于2019-11-14得票数 0
3回答
文档中示例的一个简化版本是： ws = web.WebSocketResponse() async for message in ws:在本例中，ws是对与客户端的w
浏览 8提问于2016-03-05得票数 5
回答已采纳
1回答
由于计算需要很长时间，我已经实现了一个C++线程池(如)，并编写了一个函数std::future<result_type> compute_threaded(input_type input)，该函数返回一个在线程池执行完成后就可以准备好的未来我想要做的是在python中也使用这个C++函数。要做到这一点，一个简单的方法是包装std::future<result_type>，包括它的get()函数，等待如下所有结果：
def compute_total_results_parall
浏览 3提问于2020-09-25得票数 4
回答已采纳
我是在一个excel用户表单在VBA中工作。我正在尝试完成的是我有一系列的文本框，它们将在excel中填充各种单元格。一旦用户单击了名为"Submit“的命令按钮，就会出现一个消息框(使用"vbOkOnly")，要求用户在提交信息之前验证表单上的信息。在用户单击消息框上的"OK“之后，它返回到用户表单。如果所有信息都是正确的，则用户再次单击“提交”按钮，此时信息将被放入适当的单元格中。所以我想计算一下“提交”按钮的点击量，在两次点
浏览 0提问于2018-05-11得票数 0
如何在Quart中的另一个异步方法中调用主线程中获取事件循环的异步方法？(websocket_context)
File "C:\Users\Smart\AppData\Local\Programs\Python\Python37-32\lib\site-packages_on_completion() at C:\Users\Smart\AppData\Local\Programs\Python\Python37-32\lib\
浏览 0提问于2019-06-20得票数 7
回答已采纳
2回答
当调用该库上的函数时，将发布一条消息，以便在该远程计算机上进行处理。一旦处理完成，它就会在总线上发布一条新消息，由我的库获取该消息，并将结果返回给调用代码(调用库函数的代码)。在Javascript中，这是通过返回一个具有resolve & reject函数的允诺来实现的，该允诺可以存储在库中，直到远程消息通过代理返回，结果(在库的其他地方被截获)，此时我只需调用先前存储的“现在在Python</em
浏览 1提问于2019-11-14得票数 1
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
云直播
对象存储
腾讯会议活动推荐
腾讯云开发者
