5.3. サポートサービスの管理

一時的な永続性は、各サービス専用の組み込み PostgreSQL データベースを使用します。OpenShift Serverless Logic Operator は、すべてのサービスの再起動でこのデータベースを再作成し、開発およびテストの目的でのみ適切になるようにします。次の SonataFlowPlatform CR 以外の追加の設定は必要ありません。

apiVersion: sonataflow.org/v1alpha08
kind: SonataFlowPlatform
metadata:
  name: sonataflow-platform-example
  namespace: example-namespace
spec:
  services:
    dataIndex:
      enabled: true
      # Specific configurations for the Data Index Service
      # might be included here
    jobService:
      enabled: true
      # Specific configurations for the Job Service
      # might be included here

データベースの移行とは、特定の Data Index データベースまたは Jobs Service データベースをそれぞれのスキーマに初期化すること、または新しいバージョンがリリースされた際にデータまたはスキーマの更新を適用することを指します。dataIndex.persistence.dbMigrationStrategy および jobService.persistence.dbMigrationStrategy のオプションフィールドを使用して、サポートサービスごとにデータベース移行ストラテジーを個別に設定する必要があります。移行ストラテジーを設定しない場合、システムは service をデフォルト値として使用します。

次のいずれかのデータベース移行ストラテジーを設定できます。

PostgreSQL の永続性の場合、クラスターに PostgreSQL サーバーインスタンスをセットアップする必要があります。このインスタンスの管理は、OpenShift Serverless Logic Operator 制御とは独立して維持されます。サポートサービスを PostgreSQL サーバーに接続するには、適切なデータベース接続パラメーターを設定する必要があります。

次の例を使用して、SonataFlowPlatform CR で PostgreSQL の永続性を設定できます。

apiVersion: sonataflow.org/v1alpha08
kind: SonataFlowPlatform
metadata:
  name: sonataflow-platform-example
  namespace: example-namespace
spec:
  services:
    dataIndex:
      enabled: true
      persistence:
        dbMigrationStrategy: job 

        postgresql:
          serviceRef:
            name: postgres-example 

            namespace: postgres-example-namespace 

            databaseName: example-database 

            databaseSchema: data-index-schema 

            port: 1234 

          secretRef:
            name: postgres-secrets-example 

            userKey: POSTGRESQL_USER 

            passwordKey: POSTGRESQL_PASSWORD 

    jobService:
      enabled: true
      persistence:
        dbMigrationStrategy: job
        postgresql:
        # Specific database configuration for the Job Service
        # might be included here.

次のコマンドを実行して、PostgreSQL にアクセスするためのシークレットを作成します。

$ oc create secret generic <postgresql_secret_name> \
  --from-literal=POSTGRESQL_USER=<user> \
  --from-literal=POSTGRESQL_PASSWORD=<password> \
  -n <namespace>

OpenShift Serverless Logic Operator は、サポートサービスを spec.persistence フィールドで設定された共通の PostgreSQL サーバーに自動的に接続します。

ルールの場合、以下の優先順位が適用されます。

SonataFlowPlatform カスタムリソース (CR) の spec.persistence.postgresql フィールドを使用して、すべてのサポートサービスに共通の PostgreSQL サービスとデータベースを設定できます。このフィールドが設定されると、OpenShift Serverless Logic Operator はサポートサービスを指定されたデータベースに接続します。preview または gitops プロファイルを使用して同じ namespace にデプロイされ、カスタム永続性設定を指定していないワークフローも、このデータベースに接続します。

プラットフォームスコープの永続性を設定する場合は、次のルールが適用されます。

次の SonataFlowPlatform CR フラグメントは、プラットフォームスコープの PostgreSQL 永続性を設定する方法を示しています。

apiVersion: sonataflow.org/v1alpha08
kind: SonataFlowPlatform
metadata:
  name: sonataflow-platform-example
  namespace: example-namespace
spec:
  persistence:
    postgresql:
      serviceRef:
        name: postgres-example 

        namespace: postgres-example-namespace 

        databaseName: example-database 

        port: 1234 

      secretRef:
        name: postgres-secrets-example 

        userKey: POSTGRESQL_USER 

        passwordKey: POSTGRESQL_PASSWORD 

    dataIndex:
      enabled: true
      persistence:
        dbMigrationStrategy: job 

    jobService:
      enabled: true
      persistence:
        dbMigrationStrategy: service 

プラットフォームスコープのイベントシステムを設定するには、SonataFlowPlatform CR の spec.eventing.broker.ref フィールドを使用して、Knative Eventing Broker を参照します。この設定は、指定されたブローカーを使用して、サポートサービスを自動的にリンクし、イベントを生成および消費するように OpenShift Serverless Logic Operator に指示します。

preview または gitops プロファイルで同じ namespace にデプロイされ、カスタムのイベントシステム設定がないワークフローは、自動的に指定されたブローカーにリンクされます。

次の例は、プラットフォームスコープのイベントシステムに SonataFlowPlatform CR を設定する方法を示しています。

apiVersion: sonataflow.org/v1alpha08
kind: SonataFlowPlatform
metadata:
  name: sonataflow-platform-example
  namespace: example-namespace
spec:
  eventing:
    broker:
      ref:
        name: example-broker 

        namespace: example-broker-namespace 

        apiVersion: eventing.knative.dev/v1
        kind: Broker

サービススコープのイベントシステム設定により、イベントシステム (特に Data Index または Job Service) を細かく制御できます。

Data Index のサービススコープのイベントシステムを設定するには、SonataFlowPlatform CR の spec.services.dataIndex.source.ref フィールドを使用して、特定の Knative Eventing Broker を参照する必要があります。この設定は、OpenShift Serverless Logic Operator に対して、その Broker からの SonataFlow システムイベントを消費するように Data Index を自動的にリンクするように指示します。

次の例は、Data Index イベントシステム設定を表示しています。

apiVersion: sonataflow.org/v1alpha08
kind: SonataFlowPlatform
metadata:
  name: sonataflow-platform-example
spec:
  services:
    dataIndex:
      source:
        ref:
          name: data-index-source-example-broker 

          namespace: data-index-source-example-broker-namespace 

          apiVersion: eventing.knative.dev/v1
          kind: Broker

Job Service 用にサービススコープのイベントシステムを設定するには、SonataFlowPlatform CR の spec.services.jobService.source.ref および spec.services.jobService.sink.ref フィールドを使用する必要があります。これらのフィールドは、指定された設定に基づいて、Job Service を自動的にリンクして SonataFlow システムイベントを消費するように、OpenShift Serverless Logic Operator に指示します。

次の例は、Job Service のイベントシステム設定を表示しています。

apiVersion: sonataflow.org/v1alpha08
kind: SonataFlowPlatform
metadata:
  name: sonataflow-platform-example
spec:
  services:
    jobService:
      source:
        ref:
          name: jobs-service-source-example-broker 

          namespace: jobs-service-source-example-broker-namespace 

          apiVersion: eventing.knative.dev/v1
          kind: Broker
      sink:
        ref:
          name: jobs-service-sink-example-broker 

          namespace: jobs-service-sink-example-broker-namespace 

          apiVersion: eventing.knative.dev/v1
          kind: Broker

クラスタースコープのサポートサービスをデプロイする場合、サポートサービスは、SonataFlowClusterPlatform CR によって参照される SonataFlowPlatform CR で指定された Broker に自動的にリンクされます。

OpenShift Serverless Logic Operator は定義された優先順位に従って、サポートサービスのイベントシステムを設定します。

Eventing システム設定の優先度ルールは以下のとおりです。

OpenShift Serverless Logic Operator は、サポートサービスをイベントシステムにリンクするために、Knative Eventing、SinkBindings、およびトリガーを自動的に作成します。これらのオブジェクトにより、サポートサービスによるイベントの生成と消費が可能になります。

次の例は、SonataFlowPlatform CR 用に作成された Knative Native イベントオブジェクトを示しています。

apiVersion: sonataflow.org/v1alpha08
kind: SonataFlowPlatform
metadata:
  name: sonataflow-platform-example
  namespace: example-namespace
spec:
  eventing:
    broker:
      ref:
        name: example-broker 

        apiVersion: eventing.knative.dev/v1
        kind: Broker
  services:
    dataIndex: 

      enabled: true
    jobService: 

      enabled: true

次の例は、SonataFlowPlatform CR で使用する Knative Kafka Broker を設定する方法を示しています。

apiVersion: eventing.knative.dev/v1
kind: Broker
metadata:
  annotations:
    eventing.knative.dev/broker.class: Kafka 

  name: example-broker
  namespace: example-namespace
spec:
  config:
    apiVersion: v1
    kind: ConfigMap
    name: kafka-broker-config
    namespace: knative-eventing

次のコマンドは、どのサービスがイベントにサブスクライブされているかを示す、Data Index および Job Service イベントにセットアップされたトリガーのリストを表示します。

$ oc get triggers -n example-namespace

NAME                                                        BROKER           SINK                                                       AGE   CONDITIONS   READY   REASON
data-index-jobs-fbf285df-c0a4-4545-b77a-c232ec2890e2        example-broker   service:sonataflow-platform-example-data-index-service     106s  7 OK / 7    True    -
data-index-process-definition-e48b4e4bf73e22b90ecf7e093ff6b1eaf   example-broker   service:sonataflow-platform-example-data-index-service     106s  7 OK / 7    True    -
data-index-process-error-fbf285df-c0a4-4545-b77a-c232ec2890e2   example-broker   service:sonataflow-platform-example-data-index-service     106s  7 OK / 7    True    -
data-index-process-instance-mul35f055c67a626f51bb8d2752606a6b54   example-broker   service:sonataflow-platform-example-data-index-service     106s  7 OK / 7    True    -
data-index-process-node-fbf285df-c0a4-4545-b77a-c232ec2890e2      example-broker   service:sonataflow-platform-example-data-index-service     106s  7 OK / 7    True    -
data-index-process-state-fbf285df-c0a4-4545-b77a-c232ec2890e2     example-broker   service:sonataflow-platform-example-data-index-service     106s  7 OK / 7    True    -
data-index-process-variable-ac727d6051750888dedb72f697737c0dfbf   example-broker   service:sonataflow-platform-example-data-index-service     106s  7 OK / 7    True    -
jobs-service-create-job-fbf285df-c0a4-4545-b77a-c232ec2890e2    example-broker   service:sonataflow-platform-example-jobs-service         106s  7 OK / 7    True    -
jobs-service-delete-job-fbf285df-c0a4-4545-b77a-c232ec2890e2    example-broker   service:sonataflow-platform-example-jobs-service         106s  7 OK / 7    True    -

Job Service の SinkBinding リソースを表示するには、以下のコマンドを使用します。

$ oc get sources -n example-namespace

NAME                                          TYPE          RESOURCE                           SINK                    READY
sonataflow-platform-example-jobs-service-sb   SinkBinding   sinkbindings.sources.knative.dev   broker:example-broker   True