# Pipelines

リアルタイムデータストリームを取り込み、R2 にロードします

> 以下のリンクは、各ページの Markdown 版を直接指します。 任意のページは、`index.md` サフィックスなしの URL に `Accept: text/markdown` ヘッダーを付けて取得することもできます（例: `curl -H "Accept: text/markdown" https://developers.cloudflare.com/pipelines/`）。
>
> その他の Cloudflare 製品は、[Cloudflare ドキュメントディレクトリ](https://developers.cloudflare.com/llms.txt) を参照してください。

## 概要

- [Cloudflare Pipelines](https://developers.cloudflare.com/pipelines/index.md): ストリーミングデータを取り込み、変換し、Apache Iceberg テーブル、または Parquet と JSON ファイルとして R2 へ配信します。

## はじめに

- [はじめに](https://developers.cloudflare.com/pipelines/getting-started/index.md): 最初のパイプラインを作成し、ストリーミングデータを取り込んで R2 Data Catalog の Apache Iceberg テーブルへ書き込みます。

## Streams

- [Streams](https://developers.cloudflare.com/pipelines/streams/index.md): Cloudflare Pipelines で処理するためにイベントを受信し、保存する、耐久性のあるバッファ付きキューです。
- [ソースとしての Logpush](https://developers.cloudflare.com/pipelines/streams/logpush/index.md): Cloudflare Logpush を使い、Cloudflare 製品のログを Pipelines のストリームへ送信します。
- [ストリームを管理する](https://developers.cloudflare.com/pipelines/streams/manage-streams/index.md): データ取り込み用のストリームを作成、設定、管理します
- [ストリームへの書き込み](https://developers.cloudflare.com/pipelines/streams/writing-to-streams/index.md): Worker バインディングまたは HTTP エンドポイント経由で、ストリームにデータを送信します

## Sinks

- [Sinks](https://developers.cloudflare.com/pipelines/sinks/index.md): Cloudflare Pipelines のデータ送信先を設定し、R2 または R2 Data Catalog へ書き込みます。
- [R2](https://developers.cloudflare.com/pipelines/sinks/available-sinks/r2/index.md): 処理済みデータを JSON または Parquet ファイルとして R2 オブジェクトストレージへ書き込みます。
- [R2 Data Catalog](https://developers.cloudflare.com/pipelines/sinks/available-sinks/r2-data-catalog/index.md): 処理済みデータを Apache Iceberg テーブルとして R2 Data Catalog に書き込みます。
- [シンクの管理](https://developers.cloudflare.com/pipelines/sinks/manage-sinks/index.md): データ保存用のシンクを作成、設定、管理します

## パイプライン

- [パイプライン](https://developers.cloudflare.com/pipelines/pipelines/index.md): SQL 変換でストリームとシンクを接続し、イベントのフィルター、強化、再構成を行います。
- [パイプラインの管理](https://developers.cloudflare.com/pipelines/pipelines/manage-pipelines/index.md): ストリームとシンクのあいだで SQL 変換を作成、設定、管理します。

## 例

- [例](https://developers.cloudflare.com/pipelines/examples/index.md): Cloudflare Pipelines で構築する方法を示す例を確認します。
- [ストリームを複数の Iceberg テーブルへ振り分ける](https://developers.cloudflare.com/pipelines/examples/bluesky-firehose-fanout/index.md): 1 つの Pipelines ストリームと複数の SQL 文を使い、Bluesky Jetstream のイベントを複数の R2 Data Catalog テーブルへ振り分けます。

## observability

- [メトリクスと分析](https://developers.cloudflare.com/pipelines/observability/metrics/index.md): 取り込んだデータ、処理したデータ、配信したデータを、ダッシュボードまたは GraphQL API で照会します。

## platform

- [制限](https://developers.cloudflare.com/pipelines/platform/limits/index.md): オープンベータ期間中の、Cloudflare Pipelines のストリーム、シンク、パイプラインに対するアカウント単位の制限です。
- [料金](https://developers.cloudflare.com/pipelines/platform/pricing/index.md): Cloudflare Pipelines の SQL 変換、シンク、含まれる使用量の料金です。

## reference

- [レガシーパイプライン](https://developers.cloudflare.com/pipelines/reference/legacy-pipelines/index.md): 2025 年 9 月より前に作成したパイプラインを、新しい Pipelines アーキテクチャへ移行するガイドです。
- [REST API](https://developers.cloudflare.comhttps://developers.cloudflare.com/api/resources/pipelines/index.md)
- [Terraform](https://developers.cloudflare.com/pipelines/reference/terraform/index.md): Cloudflare プロバイダーを使い、Terraform で Pipelines と R2 Data Catalog を設定します。
- [Wrangler コマンド](https://developers.cloudflare.com/pipelines/reference/wrangler-commands/index.md): Wrangler CLI コマンドで、Pipelines の stream、sink、pipeline を管理します。

## sql-reference

- [配列関数](https://developers.cloudflare.com/pipelines/sql-reference/scalar-functions/array/index.md): 配列を操作するスカラー関数
- [バイナリ文字列関数](https://developers.cloudflare.com/pipelines/sql-reference/scalar-functions/binary-string/index.md): バイナリ文字列を操作するスカラー関数
- [条件関数](https://developers.cloudflare.com/pipelines/sql-reference/scalar-functions/conditional/index.md): 条件ロジックを実装するスカラー関数
- [ハッシュ関数](https://developers.cloudflare.com/pipelines/sql-reference/scalar-functions/hashing/index.md): 値をハッシュするスカラー関数
- [JSON 関数](https://developers.cloudflare.com/pipelines/sql-reference/scalar-functions/json/index.md): JSON を操作するスカラー関数です。
- [数学関数](https://developers.cloudflare.com/pipelines/sql-reference/scalar-functions/math/index.md): 数学演算向けのスカラー関数
- [その他の関数](https://developers.cloudflare.com/pipelines/sql-reference/scalar-functions/other/index.md): その他のスカラー関数
- [正規表現関数](https://developers.cloudflare.com/pipelines/sql-reference/scalar-functions/regex/index.md): 正規表現向けのスカラー関数
- [文字列関数](https://developers.cloudflare.com/pipelines/sql-reference/scalar-functions/string/index.md): 文字列を操作するスカラー関数
- [struct 関数](https://developers.cloudflare.com/pipelines/sql-reference/scalar-functions/struct/index.md): struct を操作するスカラー関数です。
- [日時関数](https://developers.cloudflare.com/pipelines/sql-reference/scalar-functions/time-and-date/index.md): 時刻と日付を扱うスカラー関数
- [SELECT ステートメント](https://developers.cloudflare.com/pipelines/sql-reference/select-statements/index.md): Cloudflare Pipelines の SQL でデータを変換するクエリ構文です。
- [SQL のデータ型](https://developers.cloudflare.com/pipelines/sql-reference/sql-data-types/index.md): Cloudflare Pipelines の SQL で使えるデータ型です。