#4.1 节点生命周期

从这一章开始，小莫要解锁一项大能力：✍️ 会表达——你将亲手写出它身上的第一个"零件"（节点）。

在动手敲代码之前，这一节先把一件最重要的事讲透：一个节点从"出生"到"退场"，一生到底经历了什么。 只要你脑子里有了这幅"生命周期"的画面，后面写代码就是水到渠成。

#学习目标

学完本节，你将能够：

• 说清一个 DORA 节点的三段人生：连线 → 循环收发 → 退场；
• 理解事件循环为什么长成 for event in node: 这个样子；
• 认识节点会收到的几种事件类型（INPUT / STOP / InputClosed 等）；
• 明白 send_output 是怎么"往黑板上写字"的。

#前置要求

• 读完第一章，脑子里有"黑板与课堂"的画面；
• 会一点点 Python（for、if、字典取值），不熟的话先看附录 · Python 极简速成；
• 装好了朵拉魔盒（第二章），并跑通过第三章的小飞机。

#先回到黑板教室

第一章我们说过，一个节点（Node） 就是黑板教室里的一名同学，各管一摊事：有人负责读、有人负责算、有人负责写。

那么，一名"同学"在教室里的一天是怎么过的？其实非常简单，就三步：

1. 走进教室、报到——让老师（DORA 运行时）知道"我来了，我是谁"；
2. 上课——一遍遍地：抬头看黑板（收到新数据）→ 动脑处理 → 把结果写上黑板；
3. 下课铃响、离场——听到"放学"（STOP）信号，收拾好东西，安静离开。

一个 DORA 节点的"一生"，和这个一模一样。我们给这三步起了正式的名字：

下面我们逐段拆开看。

#第一段：出生——node = Node()

一个 Python 节点的代码，几乎总是这样开头：

from dora import Node   # 从 DORA 库里，把 Node 这个"零件模板"拿进来

node = Node()           # 造出这个节点，并连上 DORA 运行时

这两行看着不起眼，背后却发生了一件关键的事：Node() 把你的这段代码，接进了整个数据流。

打个比方：Node() 就像新同学走进教室、向老师报到。报到之后，老师才知道：

• 你叫什么名字（节点的 id，来自 dataflow.yml）；
• 你该抬头看黑板的哪一块区域（你的 inputs）；
• 你能往黑板的哪一块区域写字（你的 outputs）。

#第二段：主循环——for event in node:

报到之后，节点就进入了它一生中最主要的部分：一个不停转的循环，我们叫它事件循环（Event Loop）。

for event in node:      # 一个接一个地，拿到发生的"事件"
    ...                 # 针对每个事件，决定做什么

#为什么是"事件"，而不是"数据"？

这里有个很重要的观念转变。你可能以为节点是"等数据来了就处理"，但 DORA 的说法更准确：节点等的是"事件（Event)"。

什么叫事件？就是"教室里发生的一件值得你知道的事"。新数据到了，是一件事；老师喊放学，也是一件事；某个同学提前走了，也是一件事。这些都通过同一个循环通知给你。

所以 for event in node: 的含义是：

只要教室里发生了什么和我有关的事，就把它交给我，让我处理一下。

#每个 event 长什么样？

每次循环拿到的 event，是一个字典（dict），你用中括号取里面的值。最常用的三个键：

于是一个节点处理事件的标准姿势就出来了——先看类型，再看是哪个输入，最后取数据：

for event in node:
    if event["type"] == "INPUT":        # 如果是"来数据了"这类事件
        if event["id"] == "image":      # 且这份数据来自名叫 image 的输入
            data = event["value"]       # 就把数据取出来
            # ... 在这里处理 data ...

#节点会遇到哪几种事件类型？

event["type"] 主要有这几种。零基础阶段你真正要管的只有前两种，其余先认个脸：

#第三段：退场——收到 STOP，优雅离开

节点不能永远转下去。当你在终端里停掉数据流（或数据流自然结束）时，运行时会给每个节点发一个 STOP 事件——这就是"放学铃"。

节点听到铃声，应该跳出循环、干净地退出：

for event in node:
    if event["type"] == "INPUT":
        ...                          # 正常处理数据
    elif event["type"] == "STOP":
        break                        # 收到放学铃，跳出循环

break 之后，for 循环结束，函数返回，进程退出——这个节点的"一生"就圆满收场了。

i = 0
for event in node:
    if i >= 100:
        break        # 发够了，主动退出
    i += 1
    node.send_output("data", ...)

#把三段拼成一个完整骨架

现在，把出生、循环、退场三段拼起来，你就得到了几乎所有 Python 节点都长这样的通用骨架。请仔细看这段——它是本章后面所有代码的模板：

from dora import Node          # ① 出生：拿到 Node 模板

def main():
    node = Node()              # ①   造出节点、连上运行时

    for event in node:         # ② 主循环：一遍遍收事件
        if event["type"] == "INPUT":
            data = event["value"]         # 取出数据
            # === 你的处理逻辑写在这里 ===
            # 处理完，可能把结果写回黑板：
            # node.send_output("输出名", 结果)

        elif event["type"] == "STOP":     # ③ 退场
            break                          #   收到放学铃，退出

if __name__ == "__main__":
    main()

#send_output：往黑板上写字

上面骨架里出现了 node.send_output(...)，它就是节点"把结果写到黑板上"的动作——也就是产生一个输出（Output）。它的样子是：

node.send_output("输出名", 数据)

• 第一个参数：输出的名字。它必须是你在 dataflow.yml 的 outputs 里声明过的名字（下一节会看到）。
• 第二个参数：要写出去的数据。DORA 里数据统一用 Arrow 格式（还记得第一章"黑板的统一书写规范"吗），所以通常先用 pyarrow 把它包一下：

import pyarrow as pa

node.send_output("data", pa.array([1, 2, 3, 4, 5]))

现在不必纠结 pa.array 的细节——第五章会专门讲 Arrow 数据。这一节你只要记住：send_output = 写黑板，名字要和值日表对上。

#动手练习（读代码）

下面这个节点，来自 DORA 官方示例，叫 echo（回声）。请你先别看解析，试着用"三段式"读懂它在干什么：

from dora import Node

def main():
    node = Node()
    for event in node:
        if event["type"] == "INPUT":
            node.send_output("data", event["value"], event["metadata"])
        elif event["type"] == "STOP":
            break

if __name__ == "__main__":
    main()

问题：这个节点收到数据后，做了什么？

#常见报错 FAQ

#小结

• 一个节点的一生就是三段式：出生（Node()）→ 主循环（for event in node）→ 退场（STOP 后 break）。
• 节点等的是事件，不只是数据；每个 event 是个字典，看 event["type"]、event["id"]、event["value"]。
• 最常处理两种事件：INPUT（来数据了）和 STOP（该退场了）。
• send_output("名字", 数据) 就是"往黑板上写字"，名字要和 dataflow.yml 对上。

下一节，我们就用这套"三段式"骨架，亲手写出你的第一个 Python 节点。