小编Ale*_*usk的帖子

我在Windows上开发了一个使用此代码的sikuli python脚本:

from socket import AF_INET, SOCK_DGRAM
import sys
import socket
import struct, time

host = "pool.ntp.org"
port = 123
buf = 1024
address = (host,port)
msg = '\x1b' + 47 * '\0'

# reference time (in seconds since 1900-01-01 00:00:00)
TIME1970 = 2208988800L # 1970-01-01 00:00:00

# connect to server
client = socket.socket( AF_INET, SOCK_DGRAM)
client.sendto(msg, address)
msg, address = client.recvfrom( buf )

t = struct.unpack( "!12I", msg )[10]
t -= TIME1970

current_time = time.ctime(t).replace(" "," ")

代码在linux下或在Windows上的python脚本中正常工作,但是如果我在Windows上的sikulix上使用此代码它会崩溃(在line => …

我想以编程方式执行 IPython / Jupyer 笔记本中的单元并对它们进行一些内省，例如获取用户变量。

使用 IPython.core.InteractiveShell 非常简单：

from IPython.core.interactiveshell import InteractiveShell
shell = InteractiveShell()
shell.run_cell("foo = 1")
assert shell.ns_table['user_local']['foo'] == 1

但我无法使用 InteractiveShell，因为我想捕获丰富的输出（如另一个问题中所述）。为了做到这一点，我必须使用jupyter_client，它使用 ZeroMQ 连接到内核。

我的问题是，如何从 IPython 内核的命名空间中检索对象，就像上面示例中 ns_table 所做的那样？某种样板代码注入单元源和/或用户表达式的酸洗/取消酸洗是否不可避免（如另一个问题中所讨论的）？

我正在尝试通过 redux-saga 实现图像上传。我需要包括的功能是：

• 并发上传限制。这是通过使用一个实现channel如在佐贺文档描述

• START_UPLOADS在下面的代码中，我听到的操作包含一个（可能很长）文件数组，这些文件分别发布到频道。

• 我需要能够通过另一个操作取消所有当前上传CANCEL_ACTION，包括那些到达任何 START_UPLOADS 但尚未发布到频道的上传，以及当前正在任何uploadImage工作人员中处理的上传。

我得到的代码如下。我的问题是cancelAll处理程序是在finally重新启动传奇的块之后执行的，而且我似乎需要重新启动所有内容。它看起来笨重且容易出错。您能否就这是否是 Sagas 的用途提出任何建议？

function* uploadImage(file) {
  const config = yield getConfig();
  const getRequest = new SagaRequest();
  console.log("Making async request here.");
}

function* consumeImages(uploadRequestsChannel) {
  while (true) {
    const fileAdded = yield take(uploadRequestsChannel);
    // process the request
    yield* uploadImage(fileAdded);
  }
}

function* uploadImagesSaga() {
  const CONCURRENT_UPLOADS = 10;
  const uploadRequestsChannel = yield call(channel);
  let workers = [];
  function* scheduleWorkers() {
    workers …