问题标签 [twisted.internet]
For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.
python - 如何限制 Twisted 中的同时连接数
所以我有一个我构建的扭曲服务器,我想知道限制同时连接数的最佳方法是什么?
让我的工厂返回 None 是最好的方法吗?当我这样做时,我会抛出很多异常,例如:
我希望以某种方式让客户端坐在队列中,直到当前连接数恢复正常,但我不知道如何异步执行此操作。
目前我正在使用我的工厂这样做:
这有效,但断开连接而不是等待,并且还会引发许多未处理的错误。
python - 从另一个文件调用 Scrapy 而不使用线程
我必须从另一个 python 文件中调用爬虫,为此我使用以下代码。
在运行此程序时,我收到错误消息
我能找到的唯一解决方法是使用
我不想使用它,因为我想多次调用此方法并希望在下一次调用之前停止反应器。我能做些什么来完成这项工作(也许强制爬虫在同一个“主”线程中启动)?
python-2.7 - 扭曲:如何删除静态资源?
我有一个以扭曲方式实现的基本 TCP 服务器,客户端连接到该服务器。客户端连接并发送启动 websocket 资源所需的数据。使用 TCP 客户端发送的这些详细信息,我想在扭曲的 Web 资源下添加一个高速公路 websocket 资源作为子资源。当客户端断开连接时,我想从扭曲的网络资源中删除这个孩子。请提出建议,实现这一点的最佳方法应该是什么?我可以使用 resource.delEntity(child) 吗?
到目前为止,代码如下所示:
python - 在 twisted python 中 reactor.run 之后会发生 reactor.connectTCP 吗?
我希望在反应堆运行后添加更多协议和工厂。我找不到说明这是允许的文档。当我在reactor.connectTCP 之前制作reactor.run 时,程序会在工厂中围绕buildProtocol 挂起。是否可以在reactor.run 之后将reactor.connectTCP 添加到reactor 中?
python - Python - 扭曲的客户端 - dataRecived 方法中的最大数据大小
我最近一直在使用和学习扭曲来创建 TCP 客户端套接字。
我得到了类的dataRecived
方法Protocol
,将所有数据一起返回。这意味着所有数据相互ConCat,最后从服务器返回一个长字节数据。
代码:
所以现在我的问题是:
dataRecived
方法有数据的最大大小吗?或者它的大小是无限的?如果它有最大尺寸,那是什么?我怎样才能覆盖它?
注意:我使用的是 Ubuntu 14.04、Python v3.4 和 Twisted v15.3.0。
python - Python - Twisted 客户端 - 检查 ping 循环中的 protocol.transport 连接
我正在使用 Twisted 创建 TCP 客户端套接字。我需要在 connectionMade 方法的循环间隔中检查连接状态。
为了检查连接丢失,我手动断开了我的网络,然后我检查了一些变量,如下所示:
但是断开我的网络后任何变量值都没有改变:(
我的问题是:连接丢失时会设置哪些变量?我的意思是如何检查连接状态,如果断开连接,我该如何重新连接?
python - 用于客户端 python 接口 / raw_input 的 Twisted Reactor
我正在使用 twisted 运行一个相当复杂的服务器,该服务器允许远程收集、通信和命令硬件设备。在客户端,有许多可用的数据检索和命令操作。通常我使用 wxpython 反应器与客户端反应器进行交互,但我也想设置一个更简单的命令行样式界面。
是否有一个反应器可以用来为客户端设置一个本地非阻塞的类似 python 或raw_input
样式的接口?成功访问服务器后,由于服务器端事件,服务器偶尔会在未请求的情况下向下发送数据。
我考虑过manhole
,但我对作为接口访问服务器不感兴趣,我对访问客户端数据和命令非常感兴趣。这主要用于调试,但它也可以在需要时派上用场,以创建更基本的客户端界面。
python - “d.addCallback(lambda protocol:protocol.ready)”在 Pika 的 Twisted 示例中做了什么?
Pika 的 Twisted 示例代码中的设置如下所示:
d.addCallback(lambda protocol: protocol.ready)
线路有什么作用?读取.ready
属性是否有副作用?还是addCallback
使用回调的返回值?
python - ImportError:没有名为“扭曲”的模块
我是 python 新手,我正在编写一个简单的 TCP 服务器Server.py
,我正在尝试使用这行代码导入反应器
from twisted.internet import reactor
问题是当我运行代码时出现此错误
请注意,我使用的是 OS X Yosemite,并且我已经安装了一个新的 python 版本 3.5,我怎样才能回到已经扭曲的系统内置版本?