【问题标题】:Run a cell "in continuous" in a databricks notebook在数据块笔记本中“连续”运行一个单元格
【发布时间】:2019-07-11 20:32:32
【问题描述】:

由于 eventthubs 接收器在没有新事件的超时后停止侦听,我想使用 python 从同一笔记本中的另一个单元格运行 azure databricks 笔记本中的特定单元格(段落)。 每次超时后完成时,我都需要运行此单元。这就像模拟连续运行。

【问题讨论】:

  • 不要认为您可以从另一个笔记本运行一个单元,但您可以将该单元放在它自己的笔记本中并运行它。
  • 谢谢@Jon,但每次完成时我都需要运行这个单元格。这就像模拟连续运行。
  • 在另一个笔记本中,您需要只运行一个单元,还是整个另一个笔记本?看看%run,它可以让你从另一个笔记本运行整个另一个笔记本。
  • @arboc7,我想模拟连续运行,这意味着每次完成时都必须重新运行单元格。我试图把它放在另一个笔记本中,在那个笔记本中使用 %run 来回忆前一个,但我挑战了一个循环问题。

标签: python-3.x azure-eventhub azure-databricks


【解决方案1】:

最后,我使用了while True 语句,并在语句中放入了我想要运行的代码。谢谢你们——

currentMessage = receiver.receive(timeout=600)
while True:
   for event_data in currentMessage:
        .......
        .......
        .......
    currentMessage = receiver.receive(timeout=600)
    print("end processing after timeout")

【讨论】:

    猜你喜欢
    • 2019-11-07
    • 2022-01-22
    • 2020-05-17
    • 2020-12-21
    • 2018-09-23
    • 1970-01-01
    • 1970-01-01
    • 2016-05-30
    • 1970-01-01
    相关资源
    最近更新 更多