我有两个python笔记本。
第一个检查文件是否退出数据湖。我想从这里返回一个布尔值,如果它退出,则返回 filePath。
然后,下一个笔记本将使用这些参数作为输入。这怎么可能?
我也可以在管道中使用条件 IF 来检查返回的布尔值吗?
Azure ADF 的新手
在单独的 python 脚本或 jupyter notebooks 之间传递消息的一种方法是使用 pyzmq 库。在一个笔记本中运行配对服务器,在另一个笔记本中运行配对客户端。您将看到消息从一个传递到另一个。这确实为您的代码增加了额外的依赖项,但 pyzmq 是一个成熟的包。
Pairserver.ipynb
#!/usr/bin/python3
import zmq
import random
import time
port = '5556'
context = zmq.Context()
socket = context.socket(zmq.PAIR)
socket.bind('tcp://*:%s' % port)
while True:
socket.send(b'Server message to client')
msg = socket.recv()
print(msg)
time.sleep(1)
Pairclient.ipynb
#!/usr/bin/python3
import zmq
import random
import sys
import time
port = '5556'
context = zmq.Context()
socket = context.socket(zmq.PAIR)
socket.connect("tcp://localhost:%s" % port)
while True:
msg = socket.recv()
print(msg)
socket.send_string("client message to server")
time.sleep(1)