---
title: "flow_runner"
date: 0001-01-01
summary: "flow_runner #  描述 #  flow_runner 处理器用来异步消费队列里面的请求并使用异步用于在线请求的处理流程来进行消费处理。
配置示例 #  一个简单的示例如下：
pipeline: - name: bulk_request_ingest auto_start: true keep_running: true processor: - flow_runner: input_queue: "primary_deadletter_requests" flow: primary-flow-post-processing when: cluster_available: [ "primary" ] 参数说明 #     名称 类型 说明     input_queue string 订阅的队列名称   flow string 以什么样的流程来消费队列里面的请求消息   commit_on_tag string 只有当前请求的上下文里面出现指定 tag 才会 commit 消息，默认为空表示执行完就 commit    "
---


# flow_runner

## 描述

flow_runner 处理器用来异步消费队列里面的请求并使用异步用于在线请求的处理流程来进行消费处理。

## 配置示例

一个简单的示例如下：

```
pipeline:
- name: bulk_request_ingest
  auto_start: true
  keep_running: true
  processor:
    - flow_runner:
        input_queue: "primary_deadletter_requests"
        flow: primary-flow-post-processing
        when:
          cluster_available: [ "primary" ]
```

## 参数说明

| 名称          | 类型   | 说明                                                                               |
| ------------- | ------ | ---------------------------------------------------------------------------------- |
| input_queue   | string | 订阅的队列名称                                                                     |
| flow          | string | 以什么样的流程来消费队列里面的请求消息                                             |
| commit_on_tag | string | 只有当前请求的上下文里面出现指定 tag 才会 commit 消息，默认为空表示执行完就 commit |