このクイックスタートでは、Google Cloud Pipeline Components(GCPC)SDK のインストールについて説明します。
最新リリースをインストール
次のコマンドを使用して、Python パッケージ インデックス(PyPI)から Google Cloud Pipeline Components SDK をインストールします。
pip install --upgrade google-cloud-pipeline-components
GCPC SDK でビルド済みコンポーネントを使用する
Google Cloud Pipeline コンポーネント SDK をインストールしたら、その SDK を使用してビルド済みコンポーネントをインポートできます。
サポートされているコンポーネントの SDK リファレンス情報については、google_cloud_pipeline_components
SDK のドキュメントをご覧ください。
たとえば、次のコードを使用すると、パイプラインで Dataflow コンポーネントをインポートして利用できます。
from google_cloud_pipeline_components.v1.dataflow import DataflowPythonJobOp
from kfp import dsl
@dsl.pipeline(
name=PIPELINE_NAME,
description='Dataflow launch python pipeline'
)
def pipeline(
python_file_path:str = 'gs://ml-pipeline-playground/samples/dataflow/wc/wc.py',
project_id:str = PROJECT_ID,
location:str = LOCATION,
staging_dir:str = PIPELINE_ROOT,
requirements_file_path:str = 'gs://ml-pipeline-playground/samples/dataflow/wc/requirements.txt',
):
dataflow_python_op = DataflowPythonJobOp(
project=project_id,
location=location,
python_module_path=python_file_path,
temp_location = staging_dir,
requirements_file_path = requirements_file_path,
args = ['--output', OUTPUT_FILE],
)
次のステップ
- Google Cloud パイプライン コンポーネントの概要 を確認する。
google_cloud_pipeline_components
SDK を使用するすべてのチュートリアルを確認する。- Dataflow コンポーネントを使ってみる。