4.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

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:
        postgresql:
          serviceRef:
            name: postgres-example 1
            namespace: postgres-example-namespace 2
            databaseName: example-database 3
            databaseSchema: data-index-schema 4
            port: 1234 5
          secretRef:
            name: postgres-secrets-example 6
            userKey: POSTGRESQL_USER 7
            passwordKey: POSTGRESQL_PASSWORD 8
    jobService:
      enabled: true
      persistence:
        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.eventing.broker.ref 필드를 사용하여 Knative Eventing 브로커를 참조할 수 있습니다. 이 구성은 OpenShift Serverless Logic Operator가 지정된 브로커를 사용하여 이벤트를 생성하고 사용하기 위해 지원 서비스를 자동으로 연결하도록 지시합니다.

preview 또는 gitops 프로파일이 있고 사용자 정의 이벤트 시스템 구성이 없는 동일한 네임스페이스에 배포된 워크플로우는 지정된 브로커에 자동으로 연결됩니다.

다음 예제는 플랫폼 범위 이벤트 시스템에 대해 SonataFlowPlatform CR을 구성하는 방법을 보여줍니다.

apiVersion: sonataflow.org/v1alpha08
kind: SonataFlowPlatform
metadata:
  name: sonataflow-platform-example
  namespace: example-namespace
spec:
  eventing:
    broker:
      ref:
        name: example-broker 1
        namespace: example-broker-namespace 2
        apiVersion: eventing.knative.dev/v1
        kind: Broker

서비스 범위 이벤트 시스템 구성을 사용하면 이벤트 시스템, 특히 데이터 인덱스 또는 작업 서비스를 세부적으로 제어할 수 있습니다.

데이터 인덱스에 대한 서비스 범위 이벤트 시스템을 구성하려면 특정 Knative Eventing 브로커를 참조하려면 SonataFlowPlatform CR의 spec.services.dataIndex.source.ref 필드를 사용해야 합니다. 이 구성은 OpenShift Serverless Logic Operator가 해당 브로커의 SonataFlow 시스템 이벤트를 사용하도록 데이터 인덱스를 자동으로 연결하도록 지시합니다.

다음 예제에서는 Data Index 이벤트 시스템 구성을 표시합니다.

apiVersion: sonataflow.org/v1alpha08
kind: SonataFlowPlatform
metadata:
  name: sonataflow-platform-example
spec:
  services:
    dataIndex:
      source:
        ref:
          name: data-index-source-example-broker 1
          namespace: data-index-source-example-broker-namespace 2
          apiVersion: eventing.knative.dev/v1
          kind: Broker

작업 서비스에 대한 서비스 범위 이벤트 시스템을 구성하려면 SonataFlowPlatform CR에서 spec.services.jobService.source.ref 및 spec.services.jobService.sink.ref 필드를 사용해야 합니다. 이러한 필드는 OpenShift Serverless Logic Operator가 제공된 구성을 기반으로 SonataFlow 시스템 이벤트를 사용하고 생성하도록 Job Service를 자동으로 연결하도록 지시합니다.

다음 예제에서는 작업 서비스 이벤트 시스템 구성을 표시합니다.

apiVersion: sonataflow.org/v1alpha08
kind: SonataFlowPlatform
metadata:
  name: sonataflow-platform-example
spec:
  services:
    jobService:
      source:
        ref:
          name: jobs-service-source-example-broker 1
          namespace: jobs-service-source-example-broker-namespace 2
          apiVersion: eventing.knative.dev/v1
          kind: Broker
      sink:
        ref:
          name: jobs-service-sink-example-broker 3
          namespace: jobs-service-sink-example-broker-namespace 4
          apiVersion: eventing.knative.dev/v1
          kind: Broker

클러스터 범위 지원 서비스를 배포하면 지원 서비스가 SonataFlowPlatform CR에 지정된 브로커에 자동으로 연결됩니다.

OpenShift Serverless Logic Operator는 지원 서비스에 대한 이벤트 시스템을 구성하기 위해 정의된 우선순위 순서를 따릅니다.

Eventing 시스템 구성 우선순위 규칙은 다음과 같습니다.

OpenShift Serverless Logic Operator는 Knative Eventing, SinkBindings 를 자동으로 생성하고 지원 서비스를 이벤트 시스템과 연결하는 트리거를 수행합니다. 이러한 오브젝트는 지원 서비스를 통해 이벤트의 프로덕션 및 사용을 가능하게 합니다.

다음 예제는 SonataFlowPlatform CR에 대해 생성된 Knative 네이티브 이벤트 오브젝트를 표시합니다.

apiVersion: sonataflow.org/v1alpha08
kind: SonataFlowPlatform
metadata:
  name: sonataflow-platform-example
  namespace: example-namespace
spec:
  eventing:
    broker:
      ref:
        name: example-broker 1
        apiVersion: eventing.knative.dev/v1
        kind: Broker
  services:
    dataIndex: 2
      enabled: true
    jobService: 3
      enabled: true

다음 예제는 SonataFlowPlatform CR과 함께 사용하도록 Knative Kafka Broker를 구성하는 방법을 보여줍니다.

apiVersion: eventing.knative.dev/v1
kind: Broker
metadata:
  annotations:
    eventing.knative.dev/broker.class: Kafka 1
  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    -

작업 서비스에 대한 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