📚 课程目录第4章通道（Channel）详解

第四节：第一个Nextflow脚本——Hello World，理解进程和通道

聊了这么多理论，咱们是时候动手了。

我刚开始学Nextflow的时候，第一件事就是跑通Hello World。别小看这个例子——它背后藏着整个Nextflow最核心的两个概念：进程和通道。

说白了，你只要能把这个跑通，后面那些复杂的质控流程，无非就是把这个骨架填上血肉而已。

4.1 一个最简单的Hello World

先别想太多。创建一个文件，就叫 hello.nf。

#!/usr/bin/env nextflow

process sayHello {
    output:
        stdout

    script:
        """
        echo 'Hello, Nextflow World!'
        """
}

workflow {
    sayHello()
}

然后终端里跑一下：

nextflow run hello.nf

你会看到类似这样的日志：

N E X T F L O W  ~  version 24.04.2
Launching `hello.nf` [magical_bohr] DSL2 - revision: ...
executor >  local (1)
[6e/8d1c28] process > sayHello [100%] 1 of 1
Hello, Nextflow World!

看到最后那行 Hello, Nextflow World!，恭喜，你已经跑通第一个流程了。

一点经验：如果报错说找不到 nextflow，多半是没装Java或者环境变量没配。我个人习惯在 ~/.bashrc 里把Java和Nextflow的路径写死，省得每次换终端都要重新配。

4.2 拆开看看：进程（Process）是什么？

刚才那个 process sayHello {...} 就是一个进程。进程是Nextflow里最小的执行单元。它封装了一段可以独立运行的脚本或命令。

你仔细看上面的写法，它有几个固定的部分：

进程名称：sayHello，用来标识这个进程，同一个流程里不能重名。
输入/输出声明：这里只有 output: stdout，意思是我要把标准输出吐出来。
脚本块：script {} 里放实际要执行的命令。你可以写任何Shell命令，甚至是一整段脚本。

我遇到过有人问：脚本块里能不能写Python？当然可以。Nextflow不关心你用的是什么语言，它只管把这个脚本丢给执行环境去跑。你把 echo 换成 python3 -c "print('Hello')"，一样跑得通。

4.3 再拆一个：通道（Channel）是什么？

刚才的例子里，进程直接跑了，没有从外面接收任何数据。但在真实项目中，数据是流动的。通道就是用来干这个事的——通道是数据在进程之间流动的管道。

看一个稍微复杂点的版本：

#!/usr/bin/env nextflow

greeting_ch = Channel.of('Hello', 'Bonjour', 'Hola')

process sayHello {
    input:
        val x

    output:
        stdout

    script:
        """
        echo "$x, Nextflow World!"
        """
}

workflow {
    sayHello(greeting_ch)
}

这里 Channel.of() 创建了一个通道，里面装了三个词。进程 sayHello 的输入声明 val x 表示从通道里取值，每个值会触发一次进程执行。

输出应该是：

Hello, Nextflow World!
Bonjour, Nextflow World!
Hola, Nextflow World!

  关键点：通道里的每个元素，都会让进程独立执行一次。三个词，就是三个任务。Nextflow会尽量把它们并行跑起来。

4.4 进程和通道是怎么配合的？

我画了一张图，帮你把刚才的流程串起来。

这张图你看懂了吗？其实就是三步：数据先进通道，通道把数据喂给进程，进程执行完后把结果吐到输出通道。

我当初学的时候，总觉得通道这东西很神秘。其实你把它理解成一个传送带——传送带上每个包裹（数据）都会经过处理站（进程）。处理站处理一个，送走一个，再处理下一个。

4.5 为什么这件事很重要？

咱们做空间质控的流程，说白了就是一堆处理步骤串在一起：

原始图像 → 配准 → 分割 → 提取组织区域 → 质控评估 → 报告

每一站都是一个进程，每一步的结果都是通过通道传给下一步。通道里传递的可以是一个文件路径，可以是一张图像，可以是一堆统计数据。这些都不重要，Nextflow只管把数据输送到该去的地方。

概念	比喻	在质控流程中的对应
通道	数据传送带	样本图像的文件路径列表
进程	工位上的操作工人	配准算法、分割脚本
输入/输出	工人接料和放料	输入输出声明定义了数据格式
工作流	整条流水线	从原始数据到质检报告的全流程

常见坑：我曾经在写第一个流程时，忘了给进程声明 input，结果进程执行了，但没拿到数据，日志上显示任务数为0。嗯，原因很简单——进程不知道它需要接东西，通道的数据就堵在门口进不来。

4.6 再动动手：从文件读入数据

刚才我们用的是 Channel.of() 手动创建通道。真实项目里，更多是从文件里读数据。

#!/usr/bin/env nextflow

samples_ch = Channel.fromPath('samples/*.txt')

process readAndGreet {
    input:
        path sample_file

    output:
        stdout

    script:
        def sample_name = sample_file.name - '.txt'
        """
        echo "Processing: $sample_name"
        cat $sample_file
        """
}

workflow {
    readAndGreet(samples_ch)
}

我个人的做法：要是路径复杂，我会先用 ls 确认一下文件确实在那里。Nextflow的路径解析绝大多数情况下没问题，但有一次我在集群上因为挂载路径的软链接跳转，导致 fromPath 什么都没匹配到。从那以后，我习惯在流程里加一个 view() 来观察通道里的内容。

samples_ch.view() 这个命令很实用，它能让你看到通道里到底流经了哪些文件或值，而且不会阻碍数据继续流动。

4.7 本章小结

咱们今天做的事，总结下来就三点：

写了一个能跑的Nextflow脚本，理解了 process 和 workflow 的基本结构。
区分了进程和通道——进程做事情，通道传数据。
看到了通道到进程的定向关系，一个通道可以喂给一个进程，也可以喂给多个进程（后面会讲到）。

说白了，你掌握了这些，就已经站在了搭建空间质控流程的起点上。下一节咱们会正式接触质控需要用到的真实数据集，然后用通道装起来，喂给咱们的第一个分析进程。

  记住这个模式：

  创建通道（放数据） → 定义进程（处理逻辑） → 在workflow中连接它们（跑起来）