python - “轮询”指的是什么,这段代码到底在做什么?
问题描述
我目前正在构建一个 python 脚本,用于启用和禁用交换机上的某些端口,以查看交换机将如何为质量保证目的而工作。我一直在使用一个名为 paramiko 的 Python 库,它实现了 SSH 以连接到我想要的任何设备,我指的是我的一位队友提供的遗留代码来编写更多脚本。在其中一个遗留代码文件中,有一个名为 _run_poll 的函数,我不明白它到底在做什么。
我已经尝试对“轮询”对 SSH 的含义进行一些研究,但我仍然不明白当我们运行“轮询”时会发生什么。它的定义似乎有点模糊。这是功能:
def _run_poll(self, session, timeout, input_data):
interval = 0.1
maxseconds = timeout
maxcount = maxseconds / interval
i = 0
timeout_flag = False
self.info('polling (%d, %d)' % (maxseconds, maxcount))
start = datetime.datetime.now()
start_secs = time.mktime(start.timetuple())
output = ''
session.setblocking(0)
while True:
if session.recv_ready(): # returns true if data has been buffered
data = session.recv(self.bufsize) # receive data from the channel
output += data
self.info('read %d bytes, total %d' % (len(data), len(output)))
if session.send_ready():
# We received a potential prompt.
# In the future this could be made to work more like
# pexpect with pattern matching.
if i < len(input_data):
data = input_data[input_idx] + '\n'
i += 1
self.info('sending input data %d' % (len(data)))
session.send(data)
self.info('session.exit_status_ready() = %s' % (str(session.exit_status_ready())))
if session.exit_status_ready():
break
# Timeout check
now = datetime.datetime.now()
now_secs = time.mktime(now.timetuple())
et_secs = now_secs - start_secs
self.info('timeout check %d %d' % (et_secs, maxseconds))
if et_secs > maxseconds:
self.info('polling finished - timeout')
timeout_flag = True
break
time.sleep(0.200)
self.info('polling loop ended')
if session.recv_ready():
data = session.recv(self.bufsize)
output += data
self.info('read %d bytes, total %d' % (len(data), len(output)))
self.info('polling finished - %d output bytes' % (len(output)))
if timeout_flag:
self.info('appending timeout message')
output += '\nERROR: timeout after %d seconds\n' % (timeout)
session.close()
return output
我找不到很多在线资源来描述这里发生的事情或一般的“投票”。谁能帮我解释一下究竟什么是“轮询”以及这里发生了什么?
解决方案
编程中有两种处理异步事件的方法。
一种方法是使用中断:您的代码在被某种机制“唤醒”之前不会执行,然后它会执行。必须在比代码执行位置更低的级别支持此机制。例如,微控制器具有内置的特定硬件,可以中断应用程序并跳转到特定地址以开始执行指令以处理中断。
构建中断系统很困难,并且需要大量的工作。对于某些应用程序,这是不可能的。轮询或反复检查条件直到它变为 True 几乎总是更容易(尽管效率较低),然后继续执行其他操作。
在您的示例中,请注意他如何使用while True:
循环。True 永远不会是 False,所以这个 while 循环只能被一个break
语句打破。我们发现 break 语句位于
if session.exit_status_ready():
break
因此,该代码的编写者决定不断地做某事,直到session.exit_status_ready()
为 True。由于这是 paramiko,因此他很可能通过 SSH 执行了远程命令,并等待命令完成并返回退出代码。这个循环的要点是让程序一直停留在循环中,直到命令完成执行并返回结果。它也可以超时:
if et_secs > maxseconds:
self.info('polling finished - timeout')
timeout_flag = True
break
因此,如果命令花费的时间超过maxseconds
程序将不会永远坐等。
一旦它退出循环,它就会打印:
self.info('polling loop ended')
因此,当您看到此消息时,您就知道远程命令已完成执行或超时。
轮询的目的是反复检查某些东西,直到出现某种情况。在您的情况下,该条件是“远程命令已完成执行”或“已经过了一定时间”。
推荐阅读
- php - 如何解决一般错误:1215(无法添加外键约束)
- google-cloud-platform - 更改 Google Compute Engine 的外部 IP 地理位置
- java - 等效于 NodeJS 的 Java AES-256 和 RSA 混合加密
- javascript - div内的Bootstrap触发器Dropdown给出错误
- android - 延迟触发的协程 GlobalScope
- sequelize.js - 使用 sequelize 插入时如何填充数据库默认值?
- facebook - 为什么显示“handleWindowVisibility:令牌 android.os.BinderProxy@c63b265 没有活动”?
- android - 在 Android Studio for Kotlin 中为视图创建代码检查
- r - 如何从使用 R 包 MICE 运行的模型中获取拟合值
- python - Celery 确认未注册的任务