Fuse Online에서는 코드를 작성하지 않고도 두 개 이상의 다른 애플리케이션 또는 서비스를 통합할 수 있는 웹 브라우저 인터페이스를 제공합니다. 또한 복잡한 사용 사례에 필요한 경우 코드를 도입할 수 있는 기능을 제공합니다.

Fuse Online을 사용하면 다양한 애플리케이션 간에 데이터를 전송할 수 있습니다. 예를 들어, 비즈니스 애널리스트는 Fuse Online을 사용하여 고객을 언급하고 Twitter에서 얻은 데이터를 활용하여 Cryostat 계정을 업데이트할 수 있는 정보를 캡처할 수 있습니다. 또 다른 예는 주식 거래 권장 사항을 만드는 서비스입니다. Fuse Online을 사용하여 관심 주식을 구매하거나 판매하기 위한 권장 사항을 캡처하고 해당 권장 사항을 주식 이전을 자동화하는 서비스로 전달할 수 있습니다.

간단한 통합을 생성하고 실행하려면 주요 단계는 다음과 같습니다.

또 다른 종류의 통합은 API 공급자의 통합입니다. API 공급자 통합을 통해 REST API 클라이언트가 통합 실행을 트리거하는 명령을 호출할 수 있습니다. API 공급자 통합을 생성하고 실행하려면 OpenAPI 2.0 문서를 Fuse Online에 업로드합니다. 이 문서에서는 클라이언트가 호출할 수 있는 작업을 지정합니다. 각 작업에 대해 해당 작업을 실행하는 데이터 매퍼 또는 필터 단계와 같은 연결 및 단계의 흐름을 지정하고 구성합니다. 간단한 통합에는 하나의 기본 흐름이 있으며 API 공급자 통합에는 각 작업에 대한 기본 흐름이 있습니다.

Fuse Online 대시보드를 사용하면 통합을 모니터링하고 관리할 수 있습니다. 실행 중인 통합을 확인할 수 있으며 통합을 시작, 중지 및 편집할 수 있습니다.

Fuse Online은 서로 다른 두 애플리케이션 간에 데이터를 공유하기 위해 코드를 작성하지 않으려는 금융, 인적 리소스 또는 마케팅과 같은 비즈니스 전문가를 위한 것입니다. 다양한 SaaS(Software-as-a-Service) 애플리케이션을 사용하면 비즈니스 요구 사항, 워크플로우 및 관련 데이터를 파악할 수 있습니다.

비즈니스 사용자는 Fuse Online을 사용하여 다음을 수행할 수 있습니다.

다음은 비즈니스 사용자가 코드를 작성하지 않고 수행할 수 있는 작업의 몇 가지 예입니다.

Fuse Online에는 다음과 같은 다양한 이점이 있습니다.

Fuse Online을 사용하려면 커넥터, 연결, 작업, 단계 및 흐름을 사용하여 통합을 생성합니다. 이러한 각 구성을 기본적인 이해하도록 하는 것이 좋습니다.

각 Fuse Online 설치를 Fuse Online 환경이라고 합니다. Red Hat은 Fuse Online 환경을 설치하고 관리하는 경우 OpenShift Online 또는 OpenShift Dedicated에서 실행됩니다. Fuse Online 환경을 설치하고 관리할 때 일반적으로 OpenShift Container Platform에서 실행되지만 OpenShift Dedicated에서 실행할 수 있습니다.

간단한 통합은 Fuse Online이 실행하는 일련의 정렬된 단계입니다. 이 세트에는 다음이 포함됩니다.

API 공급자 통합은 OpenAPI 스키마를 제공한 REST API 서비스를 게시합니다. REST API 클라이언트의 호출은 API 공급자 통합 실행을 트리거합니다. 호출은 REST API에서 구현하는 모든 작업을 호출할 수 있습니다. 간단한 통합에는 하나의 기본 실행 흐름이 있지만 API 공급자 통합에는 각 작업에 대한 기본 흐름이 있습니다. 각 작업 흐름은 통합 생성 시 해당 작업의 흐름에 추가한 단계에 따라 애플리케이션에 연결하고 데이터를 처리합니다. 각 작업 흐름은 호출이 트리거된 통합 실행을 통해 클라이언트에 지정하는 응답을 반환하여 종료됩니다.

연결하려는 애플리케이션은 OAuth 프로토콜을 사용하여 사용자를 인증할 수 있습니다. 이 경우 해당 애플리케이션에 액세스할 수 있는 클라이언트로 Fuse Online 환경을 등록합니다. 등록은 해당 애플리케이션의 커넥터와 연결됩니다. OAuth를 사용하는 각 애플리케이션에 한 번만 특정 Fuse Online 환경을 등록해야 합니다. 등록은 해당 커넥터에서 생성한 각 연결까지 확장됩니다.

Fuse Online에서 필요한 커넥터를 제공하지 않으면 개발자가 필요한 커넥터를 생성할 수 있습니다.

연결은 생성된 커넥터의 특정 인스턴스 중 하나입니다. 하나의 커넥터에서 여러 연결을 생성할 수 있습니다. 예를 들어 AMQ 커넥터를 사용하여 각 연결이 다른 브로커에 액세스하는 세 가지 AMQ 연결을 생성할 수 있습니다.

간단한 통합을 만들려면 연결을 선택하고 통합을 종료하는 연결, 추가 애플리케이션에 액세스하기 위한 하나 이상의 연결(선택 사항)을 선택합니다. API 공급자 통합을 생성하려면 각 작업 흐름에 하나 이상의 연결을 추가할 수 있습니다. 통합 및 작업 흐름의 개수는 동일한 연결을 사용할 수 있습니다. 특정 통합 또는 흐름은 동일한 연결을 두 번 이상 사용할 수 있습니다.

자세한 내용은 통합하려는 애플리케이션에 대한 연결 정보를 참조하십시오.

일부 작업에는 추가 구성이 필요하며 Fuse Online에서 이 정보를 입력하라는 메시지를 표시합니다.

각 단계는 데이터에 대해 작동합니다. 일부 단계는 Fuse Online 외부의 애플리케이션 또는 서비스에 연결된 동안 데이터에서 작동합니다. 이러한 단계는 연결입니다. 연결 간에 Fuse Online 데이터에서 작동하는 다른 단계가 있을 수 있습니다. 일반적으로 단계 세트에는 이전 연결에 사용된 데이터 필드를 흐름의 다음 연결에 사용되는 데이터 필드에 매핑하는 단계가 포함됩니다. 간단한 통합에서 시작 연결을 제외하고 각 단계는 이전 단계에서 수신하는 데이터에 대해 작동합니다.

연결 간 데이터 작업을 위해 Fuse Online에서는 다음에 대한 단계를 제공합니다.

Fuse Online에 내장되지 않은 방식으로 연결 간에 데이터 작업을 수행하려면 사용자 지정 단계를 제공하는 확장을 업로드할 수 있습니다. Fuse Online 확장 개발을 참조하십시오.

간단한 통합에는 하나의 기본 흐름이 있습니다. API 공급자 통합에는 REST API에서 정의하는 각 작업에 대한 기본 흐름이 있습니다. 각 작업의 기본 흐름은 해당 작업을 호출하는 호출을 처리하는 일련의 단계입니다.

기본 흐름에는 조건부 흐름이 있을 수 있습니다. 통합은 사용자가 지정하는 조건을 평가하여 연결된 흐름을 실행할지 여부를 결정합니다.

흐름에서는 각 단계가 이전 단계의 출력된 데이터에 대해 작동할 수 있습니다. 흐름에 필요한 단계를 확인하려면 통합 계획에 대한 고려 사항을 참조하십시오.

통합을 생성하기 전에 다음 질문을 고려하십시오.

통합 실행을 트리거하려면 어떻게 해야 합니까?

간단한 통합을 완료하려면 다음을 수행합니다.

흐름의 단계에서는 다음과 같습니다.

Fuse Online 콘솔에 로그인한 후 통합할 애플리케이션에 대한 연결 생성을 시작할 수 있습니다. 통합할 각 애플리케이션에 OAuth 프로토콜을 사용하는 경우 해당 애플리케이션의 클라이언트로 Fuse Online을 등록합니다. 다음을 포함하여 등록해야 하는 애플리케이션은 다음과 같습니다.

이러한 애플리케이션에 대한 등록 시 간단한 통합을 생성하는 워크플로우는 다음과 같습니다.

Fuse Online을 사용하여 간단한 통합을 만드는 데 필요한 워크플로를 이해하는 가장 좋은 방법은 샘플 통합 튜토리얼에 따라 샘플 통합을 생성하는 것입니다.

다음 다이어그램에서는 데이터베이스 통합에 샘플 Cryostat를 생성하는 워크플로를 보여줍니다.

통합을 게시하면 통합을 실행할 준비가 되면 Fuse Online 대시보드에 통합 이름 옆에 Running 이 표시됩니다.

연결을 만들려면 연결하려는 애플리케이션의 커넥터를 선택한 다음 입력 필드에 값을 입력하여 해당 애플리케이션에 대한 연결을 구성합니다. 애플리케이션에 따라 다르게 제공해야 하는 구성 세부 정보입니다. 연결을 구성한 후 동일한 애플리케이션에 대한 다른 연결과 구별하는 데 도움이 되는 이름을 지정합니다. 선택적으로 연결에 대한 설명을 지정할 수 있습니다.

동일한 커넥터를 사용하여 해당 애플리케이션에 대한 여러 연결을 생성할 수 있습니다. 예를 들어 AMQ 커넥터를 사용하여 세 가지 다른 연결을 생성할 수 있습니다. 각 AMQ 연결은 다른 브로커를 지정할 수 있습니다.

예를 들면 다음과 같습니다.

통합에서는 OAuth 프로토콜을 사용하여 액세스 요청을 인증하는 애플리케이션에 연결할 수 있습니다. 이렇게 하려면 해당 애플리케이션에 액세스하려면 Fuse Online 설치를 등록해야 합니다. 등록은 Fuse Online 설치의 모든 연결을 지정된 애플리케이션에 부여합니다. 예를 들어 Fuse Online 설치를 Cryostat에 등록하는 경우 Fuse Online 설치에 대한 모든 연결은 등록 시 동일한 Cryostat 클라이언트 ID와 동일한 Cryostat 클라이언트 시크릿을 사용합니다.

각 Fuse Online 환경에서 OAuth를 사용하는 각 애플리케이션에 대해 클라이언트로 Fuse Online의 등록은 하나만 필요합니다. 이 등록을 사용하면 여러 연결을 만들 수 있으며 각 연결은 다른 사용자 자격 증명을 사용할 수 있습니다.

연결하려는 각 OAuth 애플리케이션에 대해 특정 단계가 다르지만 등록은 항상 Fuse Online 환경에 클라이언트 ID와 클라이언트 시크릿을 제공합니다. 일부 애플리케이션은 클라이언트 ID 및 클라이언트 시크릿에 다른 레이블을 사용합니다. 예를 들어 Cryostat는 소비자 키와 소비자 시크릿을 생성합니다.

일부 OAuth 애플리케이션의 경우 Fuse Online은 등록에서 제공하는 클라이언트 ID 및 클라이언트 시크릿을 추가하기 위한 설정 페이지에서 항목을 제공합니다. 적용되는 애플리케이션을 확인하려면 Fuse Online의 왼쪽 패널에서 설정을 클릭합니다.

Fuse Online에서 OAuth를 사용하는 애플리케이션에 액세스할 수 있는 권한을 얻은 후 해당 애플리케이션에 대한 하나 이상의 연결을 생성할 수 있습니다. OAuth 애플리케이션에 대한 연결을 생성하면 Fuse Online에서 유효성을 검증하여 권한 부여를 확인합니다. 언제든지 연결을 다시 검증하여 권한 부여가 여전히 있는지 확인할 수 있습니다.

일부 OAuth 애플리케이션은 만료 날짜가 있는 액세스 토큰을 부여합니다. 액세스 토큰이 만료되면 애플리케이션에 다시 연결하여 새 액세스 토큰을 가져올 수 있습니다.

OAuth를 사용하거나 OAuth 애플리케이션의 새 액세스 토큰을 가져오는 연결을 검증하려면 다음을 수행합니다.

검증 또는 재연결이 실패하는 경우 애플리케이션/서비스 공급자로 확인하여 애플리케이션의 OAuth 키, ID, 토큰 또는 시크릿이 여전히 유효한지 확인합니다. 항목이 만료되었거나 취소되었을 수 있습니다.

OAuth 항목이 유효하지 않거나 만료되었거나 취소된 경우 새 값을 가져와 애플리케이션의 Fuse Online 설정에 붙여넣습니다. 연결이 검증되지 않은 애플리케이션을 등록하려면 Fuse Online 연결 및 애플리케이션 및 서비스 관련 지침을 참조하십시오. 업데이트된 설정을 사용하여 위의 지침에 따라 업데이트된 연결의 유효성을 검사합니다. 유효성 검사가 성공하고 이 연결을 사용하는 통합이 실행 중인 경우 통합을 다시 시작합니다. 통합을 다시 시작하려면 중지한 다음 시작합니다.

유효성 검사가 실패하고 다시 연결하는 데 실패하지만 서비스 공급자에서 모든 항목이 유효한 것으로 표시되면 Fuse Online 환경을 애플리케이션으로 다시 등록한 다음 연결을 다시 만듭니다. Fuse Online은 다시 생성할 때 연결을 검증합니다. 연결을 다시 생성하고 연결을 사용하는 통합이 있는 경우 통합을 편집하여 이전 연결을 삭제하고 새 연결을 추가해야 합니다. 통합이 실행 중인 경우 중지한 후 다시 시작해야 합니다.

간단한 통합 또는 작업 흐름에 연결을 추가하면 Fuse Online에서 애플리케이션에 연결할 때 연결이 수행할 수 있는 작업 목록을 표시합니다. 정확히 하나의 작업을 선택해야 합니다. 실행 중인 통합에서 각 연결은 선택한 작업만 수행합니다. 예를 들어, Twitter 연결을 통합의 시작 연결로 추가할 때 Twitter 처리를 언급하는 Twitter에서 Twitter를 모니터링하는 작업을 선택할 수 있습니다.

일부 작업을 선택하면 작업을 구성하는 하나 이상의 매개변수를 지정하라는 메시지가 표시됩니다. 예를 들어 Integration에 Cryostat 연결을 추가하고 On create 작업을 선택하면 리드 또는 연락처와 같이 사용자가 원하는 생성을 생성하는 오브젝트 유형을 표시해야 합니다.

연결을 만든 후 Fuse Online에서 내부 식별자를 연결에 할당합니다. 이 식별자는 변경되지 않습니다. 연결의 이름, 설명 또는 구성 값을 변경하고 Fuse Online에서 동일한 연결로 인식할 수 있습니다.

연결에 대한 정보를 보고 편집하는 방법은 다음 두 가지가 있습니다.

연결 세부 정보 페이지에서 편집하려는 연결에 대해 필드 옆에 있는 를 클릭하여 해당 필드를 편집합니다. 또는 구성 필드 아래에 있는 일부 연결의 경우 편집 을 클릭하여 구성 값을 변경합니다. 값을 변경하는 경우 저장을 클릭합니다.

실행 중인 통합에 사용되는 연결을 업데이트하는 경우 통합을 다시 게시해야 합니다.

OAuth 프로토콜을 사용하여 액세스 권한을 부여하는 애플리케이션의 경우 연결에 사용하는 로그인 인증 정보를 변경할 수 없습니다. 애플리케이션에 연결하고 다른 로그인 인증 정보를 사용하려면 새 연결을 생성해야 합니다.

사용자 지정 커넥터를 정의하는 확장을 업로드하면 사용자 정의 커넥터를 사용할 수 있습니다. Fuse Online 제공 커넥터를 사용하여 연결을 생성하는 것과 동일한 방식으로 사용자 지정 커넥터를 사용하여 연결을 생성합니다.

사용자 지정 커넥터는 OAuth 프로토콜을 사용하는 애플리케이션에 사용할 수 있습니다. 이러한 종류의 커넥터에서 연결을 생성하기 전에 커넥터가 제공되는 애플리케이션에 액세스하려면 Fuse Online 환경을 등록해야 합니다. 커넥터가 사용되는 애플리케이션의 인터페이스에서 이 작업을 수행합니다. Fuse Online 환경을 등록하는 방법에 대한 세부 정보는 애플리케이션마다 다릅니다.

예를 들어 사용자 지정 커넥터가 Cryostat에 대한 연결을 만드는 것이라고 가정합니다. Cryostat 내에서 새 애플리케이션을 생성하여 Fuse Online 환경을 등록해야 합니다. 등록은 Fuse Online의 경우 Cryostat 클라이언트 ID와 Fuse Online의 경우 클라이언트 시크릿 값을 제공합니다. Fuse Online 환경에 대한 연결에서는 이 두 값을 제공해야 합니다.

애플리케이션은 소비자 ID 또는 소비자 시크릿과 같은 이러한 값에 다른 이름을 사용할 수 있습니다.

Fuse Online 환경을 등록한 후 애플리케이션에 대한 연결을 만들 수 있습니다. 연결을 구성할 때 클라이언트 ID와 클라이언트 시크릿을 입력하기 위한 매개변수가 있어야 합니다. 이러한 매개변수를 사용할 수 없는 경우 확장 개발자와 통신하고 클라이언트 ID 및 클라이언트 시크릿을 지정할 수 있는 업데이트된 확장을 요청해야 합니다.

통합 생성 준비는 통합을 계획하기 위한 고려 사항에 나열된 질문에 대한 답변으로 시작됩니다. 통합 계획을 세우면 통합을 생성하기 전에 다음을 수행해야 합니다.

통합을 생성할 때 통합의 첫 번째 단계는 통합 실행이 트리거되는 방식을 결정합니다. 통합의 첫 번째 단계는 다음 중 하나일 수 있습니다.

Fuse Online에서는 간단한 통합 생성 절차를 안내합니다. 시작 연결, 완료 연결, 중간 연결 및 기타 단계를 선택하라는 메시지를 표시합니다. 통합이 완료되면 실행 중이거나 나중에 게시하기 위해 저장할 수 있도록 게시할 수 있습니다.

API 공급자 통합을 생성하는 절차에 대한 자세한 내용은 6.3절. “API 공급자 통합 생성” 을 참조하십시오.

지정한 일정에 따라 통합 실행을 트리거하려면 간단한 통합 시작 연결로 타이머 연결을 추가합니다. 타이머 연결은 흐름의 중간이나 흐름의 끝에 있을 수 없습니다.

경우에 따라 연결에서 동일한 유형의 여러 값을 포함하는 컬렉션을 반환합니다. 연결이 컬렉션을 반환하면 다음을 포함하여 여러 가지 방법으로 컬렉션에서 흐름이 작동할 수 있습니다.

흐름에서 컬렉션에 대해 작동하는 방법을 결정하려면 흐름이 연결되는 애플리케이션, 컬렉션을 처리할 수 있는지 여부 및 흐름에 달성하려는 애플리케이션을 알아야 합니다. 그런 다음 다음 항목의 정보를 사용하여 컬렉션을 처리하는 흐름에 단계를 추가할 수 있습니다.

필수 사항은 아니지만 필요한 모든 연결을 기본 흐름에 추가한 다음 흐름을 실행하려는 처리에 따라 연결 사이에 추가 단계를 추가하는 것이 좋습니다. 흐름에서 각 단계는 이전 연결 및 이전 단계에서 얻은 데이터에서 작동합니다. 결과 데이터는 흐름의 다음 단계에서 사용할 수 있습니다.

종종 연결에서 수신되는 데이터 필드를 흐름의 다음 연결이 작동할 수 있는 데이터 필드에 매핑해야 합니다. 흐름에 대한 모든 연결을 추가한 후 흐름 시각화를 확인합니다. 입력 데이터에서 작동하기 전에 데이터 매핑이 필요한 각 연결에 대해 Fuse Online은 을 표시합니다. 이 아이콘을 클릭하여 데이터 유형 Mismatch: Add a data mapper step before this connection to resolve the difference를 참조하십시오.

메시지의 링크를 클릭하여 데이터 매퍼 단계를 추가하고 지정하는 Mapper 구성 페이지를 표시할 수 있습니다. 그러나 다른 필요한 단계를 추가한 다음 데이터 매퍼 단계를 마지막으로 추가하는 것이 좋습니다.

흐름에서 조건부 흐름 단계는 사용자가 지정하는 조건에 대해 통합 데이터를 평가합니다.In a flow, a Conditional Flows step evaluates integration data against conditions that you specify. 지정된 각 조건에 대해 해당 조건과 연결된 흐름에 연결 및 기타 단계를 추가합니다. 실행 중에 조건부 흐름 단계는 들어오는 데이터를 평가하여 실행할 흐름을 결정합니다.

다음 주제에서는 세부 정보를 제공합니다.

거의 모든 통합에는 데이터 매핑이 필요합니다. 데이터 매퍼 단계는 이전 연결의 데이터 필드와 기타 단계를 흐름의 다음 연결이 작동할 수 있는 데이터 필드에 매핑합니다. 예를 들어 통합 데이터에 Name 필드가 포함되어 있고 흐름의 다음 연결에 CustomerName 필드가 있다고 가정합니다. 소스 이름 필드를 대상 Customer Name 필드에 매핑해야 합니다.

흐름에 단계를 추가하여 흐름이 작동하는 데이터를 필터링할 수 있습니다. 필터 단계에서 Fuse Online은 데이터를 검사하고 콘텐츠가 정의한 기준을 충족하는 경우에만 계속됩니다. 예를 들어, Twitter에서 데이터를 가져오는 흐름에서 "Red Hat"이 포함된 notify에서만 작동하여 계속 실행하도록 지정할 수 있습니다.

필터 단계에서 Fuse Online은 데이터를 검사하고 콘텐츠가 정의한 기준을 충족하는 경우에만 흐름을 계속 실행합니다. 기본 필터 단계에서 필요한 정확한 필터를 정의하지 않으면 고급 필터 단계를 추가합니다.

이러한 흐름에서 Fuse Online은 본문 속성 내에 실제 메시지 콘텐츠를 래핑합니다. 즉, 고급 필터에 대한 입력에는 실제 메시지 콘텐츠가 포함된 다른 본문 속성이 포함된 본문 속성이 포함됩니다. 결과적으로 이러한 종류의 흐름 중 하나에 있는 고급 필터 표현식에서 본문 의 두 인스턴스를 지정해야 합니다. 예를 들어 입력 메시지의 완료된 필드에 있는 콘텐츠를 평가한다고 가정합니다. 다음과 같이 표현식을 지정합니다.

${body.body.completed} = 1

흐름에서 템플릿 단계는 소스의 데이터를 가져와 Fuse Online에 업로드하는 템플릿에 정의된 형식으로 삽입합니다. 템플릿 단계의 이점은 사용자가 지정하는 일관된 형식으로 데이터 출력을 제공하는 것입니다.

템플릿에서 자리 표시자를 정의하고 정적 텍스트를 지정합니다. 흐름을 생성할 때 템플릿 단계를 추가하고 소스 필드를 템플릿 자리 표시자에 매핑한 다음 템플릿 콘텐츠를 흐름의 다음 단계에 매핑합니다. Fuse Online에서 흐름을 실행할 때 매핑된 소스 필드에 있는 값을 템플릿 인스턴스에 삽입하고 그 결과를 흐름의 다음 단계에서 사용할 수 있도록 합니다.

흐름에 템플릿 단계가 포함된 경우 해당 흐름의 유일한 템플릿 단계가 포함됩니다. 그러나 흐름에서 두 개 이상의 템플릿 단계가 허용됩니다.

Fuse Online에서는 다음과 같은 유형의 템플릿을 지원합니다. Freemarker,Mustache,Velocity.

At {{time}}, {{name}} tweeted:
{{text}}

Freemarker 및 Velocity는 이 예제 템플릿을 지원합니다.

At ${time}, ${name} tweeted:
${text}

속도에서는 다음 예와 같이 중괄호가 없는 구문도 지원합니다.

At $time, $name tweeted:
$text

자리 표시자는 . (period)를 포함할 수 없습니다.

Fuse Online에서 흐름에 필요한 단계를 제공하지 않는 경우 개발자는 확장에 하나 이상의 사용자 지정 단계를 정의할 수 있습니다. 사용자 지정 단계는 흐름의 연결 간 데이터에서 작동합니다.

기본 제공 단계를 추가하는 것과 동일한 방식으로 흐름에 사용자 지정 단계를 추가합니다. 간단한 통합을 위해 시작 및 완료 연결을 선택하고 필요에 따라 다른 연결을 추가한 다음 단계를 추가합니다. API 공급자 통합의 경우 흐름이 사용자 지정 단계를 실행하는 작업을 선택하고 필요에 따라 흐름에 연결을 추가한 다음 다른 단계를 추가합니다. 단계를 추가하면 Fuse Online은 흐름의 이전 단계에서 수신하는 데이터에 대해 작동합니다.

API 공급자 통합은 REST API 서비스로 시작됩니다. 이 REST API 서비스는 API 공급자 통합을 생성할 때 제공하는 OpenAPI 2.0 문서에 의해 정의됩니다. API 공급자 통합을 게시한 후 Fuse Online은 OpenShift에 REST API 서비스를 배포합니다. API 공급자 통합의 이점은 REST API 클라이언트가 통합 실행을 트리거하는 호출을 호출할 수 있다는 점입니다.

curl -k https://i-task-api-proj319352.6a63.fuse-ignite.openshiftapps.com/api/todo/1

API 공급자 통합의 OpenAPI 문서는 REST API 클라이언트가 호출할 수 있는 작업을 정의합니다. 각 OpenAPI 작업에는 자체 API 공급자 통합 흐름이 있습니다. 결과적으로 각 작업에는 자체 REST API 서비스 URL도 있을 수 있습니다. 각 URL은 API 서비스의 기본 URL에 의해 정의되며, 선택적으로 하위 경로에 의해 정의됩니다. REST API 호출은 해당 작업의 흐름 실행을 트리거하는 작업의 URL을 지정합니다.

OpenAPI 문서는 REST API 서비스 URL에 대한 호출에 지정할 수 있는 HTTP 동사(예: GET,POST,DELETE 등)를 결정합니다. API 공급자 URL에 대한 호출의 예는 API 공급자 빠른 시작 예제를 시도하는 방법에 있습니다.

또한 OpenAPI 문서에는 작업이 반환할 수 있는 가능한 HTTP 상태 코드가 결정됩니다. 작업의 반환 경로는 OpenAPI 문서에서 정의한 응답만 처리할 수 있습니다. 예를 들어 ID를 기반으로 오브젝트를 삭제하는 작업은 다음과 같은 가능한 응답을 정의할 수 있습니다.

"responses": {
  "204": {
           "description": "Task deleted"
         },
  "404": {
           "description": "No Record found with this ID"
         },
  "500": {
            "description": "Server Error"
        }
}

OpenAPI 문서를 편집하는 동안 고려 사항:

API 공급자 통합을 생성하려면 통합에서 수행할 수 있는 작업을 정의하는 OpenAPI 문서(.json,.yaml 또는 .yml 파일)를 제공합니다. Fuse Online은 각 작업에 대한 실행 흐름을 생성합니다. 각 작업의 흐름을 편집하여 해당 작업의 요구 사항에 따라 통합 데이터를 처리하는 연결 및 단계를 추가합니다.

REST API 서비스를 정의하는 OpenAPI 문서는 서비스에서 수행할 수 있는 작업을 정의합니다. API 공급자 통합을 생성한 후 각 작업에 대한 흐름을 편집할 수 있습니다.

각 작업에는 정확히 하나의 흐름이 있습니다. 작업 흐름에서는 다른 애플리케이션 및 서비스에 대한 연결과 연결 간 데이터에서 작동하는 단계를 추가할 수 있습니다.

작업 흐름을 추가하면 API 공급자 통합이 기반으로 하는 OpenAPI 문서를 업데이트해야 할 수 있습니다. 이렇게 하려면 API 공급자 통합을 편집 중인 페이지의 오른쪽 상단에 있는 API 정의 보기/ 편집을 클릭합니다. API Creator 편집기에 문서가 표시됩니다. OpenAPI 정의에서는 각 작업에 고유한 operationId 속성이 있는 한 API Splunk 및 Fuse Online에 업데이트를 저장하면 API 공급자 통합의 흐름 정의를 동기화하여 업데이트를 수행할 수 있습니다.

다른 작업의 흐름을 편집하려면 이 절차를 반복합니다.

Fuse Online에서는 Fuse Online 환경으로 가져올 수 있는 빠른 시작 API 공급자를 제공합니다. 이 빠른 시작에는 작업 관리 API를 위한 OpenAPI 문서가 포함되어 있습니다. 빠른 시작 통합을 가져온 후 흐름을 검사한 다음 통합을 게시할 수 있습니다. 아래에 설명된 절차를 완료하면 TaskAPI 통합이 실행 중이며 실행될 준비가 된 것입니다.

API 공급자 빠른 시작 기능을 사용하면 API 공급자 통합을 구성, 게시 및 테스트하는 방법을 빠르게 확인할 수 있습니다. 그러나 이는 API 공급자 통합이 얼마나 유용할 수 있는지에 대한 실제 사례가 아닙니다. 실제 예제의 경우 이미 Fuse Online을 사용하여 몇 가지 간단한 통합을 게시한다고 가정합니다. 이러한 통합 실행을 트리거하기 위해 OpenAPI 문서를 정의할 수 있습니다. 이를 위해 각 OpenAPI 작업의 흐름을 편집하여 이미 게시한 간단한 통합과 거의 동일합니다.

Fuse Online TaskAPI 빠른 시작 통합이 실행 중인 경우 HTTP 요청을 Task API 서비스에 보내는 curl 유틸리티 명령을 호출할 수 있습니다. HTTP 요청을 지정하는 방법은 호출이 트리거하는 흐름을 결정합니다.

HTTP GET 또는 POST 요청과의 통합 실행을 트리거하려면 다음을 수행해야 합니다.

HTTP GET 또는 POST 요청과의 통합 실행을 트리거하려면 Webhook 연결을 통합 시작 연결로 추가합니다.

HTTP GET 또는 POST 요청을 지정하여 간단한 통합 실행을 트리거할 수 있습니다. GET 요청은 일반적으로 데이터를 가져오고 POST 요청이 일반적으로 데이터를 업데이트하지만 두 요청 중 하나를 사용하여 두 작업 중 하나를 수행하는 통합을 트리거할 수 있습니다. 요청의 모든 매개변수는 통합에 있는 다음 연결에서 데이터 필드에 매핑할 수 있습니다. 자세한 내용은 요청 매개변수를 지정하는 JSON 스키마 정보를 참조하십시오.

Webhook 연결은 수신하는 데이터만 통합에서 다음 연결로 전달합니다. Fuse Online에서 HTTP 요청을 수신하면 다음과 같습니다.

즉, GET 요청에 의해 트리거되고 데이터를 가져오는 대신 데이터를 업데이트하는 간단한 통합을 정의할 수 있습니다. 마찬가지로 POST 요청에 의해 트리거되고 데이터를 업데이트하는 대신 데이터를 가져오는 간단한 통합을 정의할 수 있습니다.

HTTP 요청을 Fuse Online으로 전송하는 클라이언트를 구현하면 구현해야 합니다.

통합에서는 일반적으로 HTTP 요청의 헤더 및 쿼리 매개변수를 통합의 다음 연결이 처리할 수 있는 데이터 필드에 매핑합니다. 이를 위해 통합에 Webhook 연결을 추가할 때 다음 구조가 있는 JSON 스키마에 출력 데이터 유형을 지정합니다.

{
  "$schema": "http://json-schema.org/schema#",
   "id": "io:syndesis:webhook",
   "type": "object",
   "properties": {
      "parameters": {
         "type": "object",
         "properties": { 1
         }
      },
      "body": {
         "type": "object",
         "properties": { 2
         }
      }
   }
}

필요한 데이터 구조를 HTTP 요청에 대한 JSON 인스턴스에서 추가하려면 다음을 수행합니다.

HTTP 클라이언트가 보내는 모든 데이터는 통합에서 사용할 수 있지만 Webhook 연결의 데이터 셰이프가 이 JSON 스키마를 준수하는 경우 매핑에 매개변수 및 본문 콘텐츠를 사용할 수 있습니다.

예를 들어 HTTP 요청을 지정하는 방법을 참조하십시오.

다음 예제에서는 Fuse Online Webhook에 대한 HTTP 요청을 지정하는 방법을 보여줍니다.

이 통합을 생성하는 동안 Webhook 시작 연결을 추가할 때 이 콘텐츠가 있는 JSON 인스턴스로 출력 데이터 유형을 지정합니다. {"todo":"text"}:

PostgresDB 연결을 완료 연결로 추가하면 Invoke SQL 작업을 선택하고 이 SQL 문을 지정합니다.

TODO (TASK) 값 (:#TASK)을 삽입합니다.

데이터베이스 연결을 추가한 후 매핑 단계를 추가합니다.

통합을 저장하고 게시합니다. 실행 중인 경우 Fuse Online에서 제공하는 외부 URL을 복사할 수 있습니다.

외부 URL의 일부를 이해하려면 다음 샘플 URL을 고려하십시오.

https://i-webhook-to-db-myproject.192.168.64.4.nip.io/webhook/bvGvQdpq308BcHIQQYeysFOK4plFISmghNHkRyOOk3YppitvOd

외부 URL에서 볼 수 있듯이 Fuse Online은 통합 이름, OpenShift 네임스페이스 이름 및 OpenShift DNS 도메인에서 호스트 이름을 구성합니다. Fuse Online에서는 불법 문자를 제거하고 공백을 하이픈으로 변환합니다. 샘플 외부 URL에서 호스트 이름입니다.

https://i-webhook-to-db-myproject.192.168.64.4.nip.io

curl 을 사용하여 Webhook를 호출하려면 다음과 같이 명령을 지정합니다.

curl -H 'Content-Type: application/json' -d '{"todo":"from webhook"}' https://i-webhook-to-db-myproject.192.168.64.4.nip.io/webhook/bvGvQdpq308BcHIQQYeysFOK4plFISmghNHkRyOOk3YppitvOd

이 명령을 실행하면 통합을 트리거합니다. 데이터베이스 완료 연결은 새 작업을 tasks 테이블에 삽입합니다. 이를 보려면 https://todo-myproject.192.168.64.4.nip.io 에서 업데이트를 클릭하면 Webhook에서 새 작업으로 표시되는 Todo 앱을 표시합니다.

그러나 이 예제에서는 이 콘텐츠로 JSON 스키마를 지정하여 Webhook 연결 출력 데이터 유형을 정의합니다.

{
  "type": "object",
  "definitions": {},
  "$schema": "http://json-schema.org/draft-07/schema#",
  "id": "io:syndesis:webhook",
  "properties": {
    "parameters": {
      "type": "object",
      "properties": {
        "source": {
          "type": "string"
        },
        "status": {
          "type": "string"
        }
      }
    },
    "body": {
      "type": "object",
      "properties": {
        "company": {
          "type": "string"
        },
        "email": {
          "type": "string"
        },
        "phone": {
          "type": "string"
        }
      }
    }
  }
}

이 JSON 스키마에서 다음을 수행합니다.

그러면 Webhook 커넥터가 통합의 다음 단계를 위해 콘텐츠를 준비하는 데 필요한 정보가 제공됩니다.

curl 을 사용하여 HTTP 요청을 보내려면 다음과 같은 명령을 호출합니다.

curl -h 'Content-Type: application/json' -d '{"company":"Gadgets","email":" ","phone":"+1-202-555-0152"}'https://i-webhook-params-to-db-myproject.192.168.42.235.nip.io/webhook/ZYWrhaW7dVk097vNsLX3YJ1GyxUFMFRteLpw0z4O69MW7d2Kjg?source=web&status=newmailto:sales@gadgets.com

Webhook 연결이 이 요청을 수신하면 다음과 같은 JSON 인스턴스가 생성됩니다.

{
  "parameters": {
    "source": "web",
    "status": "new"
  },
  "body": {
    "company": "Gadgets",
    "email": "sales@gadgets.com",
    "phone": "+1-202-555-0152"
  }
}

이 내부 JSON 인스턴스는 다음 매핑을 활성화합니다.

curl 'https://i-webhook-params-to-db-myproject.192.168.42.235.nip.io/webhook/ZYWrhaW7dVk097vNsLX3YJ1GyxUFMFRteLpw0z4O69MW7d2Kjg'

이전 POST 예제를 변경하여 쿼리 매개변수로 GET 요청을 보낼 수 있지만 본문은 전송할 수 없습니다. 다음과 같이 Webhook 연결 출력 데이터 모양을 정의를 사용하여 JSON 스키마로 지정합니다.

{
  "type": "object",
  "definitions": {},
  "$schema": "http://json-schema.org/draft-07/schema#",
  "id": "io:syndesis:webhook",
  "properties": {
    "parameters": {
      "type": "object",
      "properties": {
        "source": {
          "type": "string"
        },
        "status": {
          "type": "string"
        }
      }
    }
  }
}

GET 요청을 보내는 curl 명령은 다음과 같습니다.

curl 'https://i-webhook-params-to-db-myproject.192.168.42.235.nip.io/webhook/ZYWrhaW7dVk097vNsLX3YJ1GyxUFMFRteLpw0z4O69MW7d2Kjg?source=web&status=new'`

Fuse Online은 경고 아이콘을 표시하여 흐름에 데이터 매핑이 필요한 위치를 나타냅니다.

비교적 몇 단계가 있는 흐름에서는 데이터 필드를 쉽고 직관적으로 매핑할 수 있습니다. 데이터 매퍼 사용 방법에 대한 몇 가지 배경이 있는 경우 더 복잡한 흐름 또는 대규모 데이터 필드를 처리하는 흐름에서 source에서 대상으로 하는 매핑이 더 쉽습니다.

데이터 매퍼는 데이터 필드의 두 열을 표시합니다.

매핑할 데이터 필드를 빠르게 찾으려면 다음 중 하나를 수행할 수 있습니다.

기본 매핑 동작은 하나의 소스 필드를 하나의 대상 필드에 매핑합니다. 예를 들어 이름 필드를 Customer Name 필드에 매핑합니다.

데이터 매핑에서는 소스 또는 대상 필드에 복합 데이터가 포함된 경우 누락되거나 원하지 않는 데이터를 식별해야 할 수 있습니다. 예를 들어 다음 형식의 long_address 필드를 고려하십시오.

개인 정보 보호 정책

long_address 필드를 숫자,Street,city,state 및 zip 에 대한 개별 필드로 분리하려고 가정하겠습니다. 이렇게 하려면 소스 필드로 long_address 를 선택한 다음 대상 필드를 선택합니다. 그런 다음 원하지 않는 소스 필드의 부분에 대한 위치에 패딩 필드를 추가합니다. 이 예에서 원하지 않는 부분은 새우주 ,zip+4 및 국가 입니다.

원치 않는 부분을 식별하려면 부품의 순서를 알아야 합니다. 순서는 복합 필드의 콘텐츠 각 부분에 대한 인덱스를 나타냅니다. 예를 들어, long_address 필드에는 8개의 정렬된 부분이 있습니다. 1에서 시작하여 각 부분의 인덱스는 다음과 같습니다.

데이터 매퍼에서는 기숙사 ,zip+4 및 country 를 식별하기 위해 인덱스 3, 7 및 8에 패딩 필드를 추가합니다. 하나의 대상 필드에 여러 소스 필드 조합을 참조하십시오.

이제 숫자,Street,city, state ,state 에 대한 소스 필드를 결합하고 long_address 대상 필드에 압축 하려고한다고 가정합니다. 또한, 기숙사 ,zip+4 및 국가에 대한 콘텐츠를 제공할 소스 필드가 없다고 가정합니다. 데이터 매퍼에서는 이러한 필드를 누락된 것으로 식별해야 합니다. 다시 말하지만 인덱스 3, 7 및 8에 패딩 필드를 추가합니다. 하나의 소스 필드를 여러 대상 필드로 분리를 참조하십시오.

데이터 매퍼 단계에서는 여러 소스 필드를 하나의 복합 대상 필드로 결합할 수 있습니다. 예를 들어 FirstName 및 LastName 필드를 CustomerName 필드에 매핑할 수 있습니다.

이 예제는 일대다 매핑의 경우이지만 원칙은 동일합니다.

데이터 매퍼 단계에서는 복합 소스 필드를 여러 대상 필드로 분리할 수 있습니다. 예를 들어 Name 필드를 FirstName 및 LastName 필드에 매핑합니다.

77 Hill Street, Brooklyn, New York, United States, 12345, 6789

주소 필드에서 콘텐츠 부분에는 다음과 같은 인덱스가 있습니다.

이제 대상 데이터에 주소에 대한 4 개의 필드가 있다고 가정합니다.

number-and-street
city
state
zip

매핑을 정의하려면 다음을 수행합니다.

이렇게 하면 대상 의 세부 정보 매핑 패널에 선택한 각 대상 필드에 대한 항목이 있습니다. 예를 들면 다음과 같습니다.

.

데이터 매퍼는 알파벳순으로 데이터 매퍼에 표시되는 순서대로 대상 항목을 표시합니다. 소스 필드에서 순서를 미러링하도록 이 순서를 변경해야 합니다. 이 예에서 source 필드에는 도시 콘텐츠 앞에 있는 number-and-street 콘텐츠가 포함되어 있습니다. 대상 항목의 순서를 수정하려면 도시 인덱스 필드를 2 로 편집하거나 number-and-street 항목 뒤에 있도록 시 항목을 드래그합니다. 결과는 다음과 같습니다.

.

대상 필드 항목에서 인덱스 번호는 이 대상 필드에 매핑될 소스 필드의 부분을 나타냅니다. 올바른 대상 필드 값을 달성하려면 인덱스 값을 변경해야 합니다. 각 대상 필드를 고려하십시오.

.

이제 이 매핑이 완료되었습니다. 소스 필드에는 인덱스 6(zip+4)에 추가 콘텐츠가 있지만 대상에 데이터가 필요하지 않으며 수행할 필요가 없습니다.

흐름에서 단계가 컬렉션을 출력하고 흐름에 있는 후속 연결이 컬렉션을 입력으로 예상하는 경우 데이터 매퍼를 사용하여 컬렉션을 처리할 방법을 지정할 수 있습니다.

단계가 컬렉션을 출력하면 흐름 시각화가 단계에 대한 세부 정보에 컬렉션을 표시합니다. 예를 들면 다음과 같습니다.

컬렉션을 제공하는 단계와 매핑이 필요한 단계 앞에 데이터 매퍼 단계를 추가합니다. 흐름에서 이 데이터 매퍼 단계는 흐름의 다른 단계에 따라 달라집니다. 다음 이미지는 소스 컬렉션 필드에서 대상 컬렉션 필드로의 매핑을 보여줍니다.

소스 및 대상 패널에서 데이터 매퍼는 를 표시하여 컬렉션을 나타냅니다. 소스 컬렉션 또는 대상 컬렉션에 기본 유형만 포함된 경우 필요하지 않기 때문에 데이터 매퍼는 컬렉션 필드를 표시하지 않습니다. 컬렉션에서 매핑하거나 컬렉션 자체에 매핑할 수 있습니다.

컬렉션에 두 가지 유형의 기본 유형이 포함되거나 하나 이상의 복잡한 유형이 포함된 경우 데이터 매퍼에서 컬렉션의 하위 필드를 표시합니다. 각 필드에서 매핑할 수 있습니다. 그러나 또는 중첩된 컬렉션으로 매핑할 수 없습니다.

Fuse Online에서 흐름을 실행하면 소스 컬렉션 요소를 반복하여 대상 컬렉션 요소를 채웁니다. 하나 이상의 소스 컬렉션 필드를 대상 컬렉션 또는 대상 컬렉션 필드에 매핑하는 경우 대상 컬렉션 요소에는 매핑된 필드에 대한 값만 포함됩니다.

소스 컬렉션의 소스 컬렉션 또는 필드를 컬렉션에 없는 대상 필드에 매핑하는 경우 Fuse Online에서 흐름을 실행할 때 소스 컬렉션의 마지막 요소 값만 할당합니다. 컬렉션의 다른 요소는 해당 매핑 단계에서 무시됩니다. 그러나 후속 매핑 단계는 소스 컬렉션의 모든 요소에 액세스할 수 있습니다.

연결에서 JSON 또는 Java 문서에 정의된 컬렉션을 반환하는 경우 데이터 매퍼는 일반적으로 소스 문서를 컬렉션으로 처리할 수 있습니다.

데이터 매퍼 소스 및 대상 패널에서 다음을 수행합니다.

데이터 매퍼의 오른쪽 상단에 있는 (COMPLEX), STRING, INTEGER 와 같은 데이터 유형 표시를 전환하려면 을 클릭하고 유형 표시를 클릭합니다.

실행하는 동안 데이터 매퍼는 대상 필드를 으로 채웁니다.

보스 파키스 파키스탄

다른 변환을 적용하여 이 기본 동작을 변경할 수 있습니다. 예를 들어 선택한 요소에서만 매핑하려면 항목 변환을 소스에 적용하고 인덱스를 지정합니다. 소스 컬렉션의 첫 번째 요소에 있는 값을 매핑하려면 인덱스에 0 을 지정합니다.

소스 컬렉션에 매핑되지 않은 필드가 포함된 경우 해당 필드는 흐름에 있는 후속 단계에서 계속 사용할 수 있습니다.

이번 릴리스에서는 분할 변환이 일대다 매핑에 적용할 수 있는 유일한 변환입니다.

예를 들어 수집이 아닌 도시 소스 필드에 다음이 포함된 경우를 살펴보겠습니다.

보스 파키스 파키스탄

이 소스 필드를 대상 컬렉션 또는 컬렉션에 있는 대상 필드에 매핑할 수 있습니다. 실행되는 동안 데이터 매퍼는 city 필드의 값을 공간 구분 기호로 분할합니다. 결과는 세 개의 요소를 포함하는 컬렉션입니다. 첫 번째 요소에서 city 필드의 값은 보스턴 입니다. 두 번째 요소에서, 시 필드의 값은 파키스탄 입니다. 세 번째 요소에서는 시 필드의 값은 Cryo stat 입니다.

데이터 매퍼에서는 매핑을 정의한 후 매핑의 모든 필드를 변환할 수 있습니다. data 필드 변환은 데이터를 저장하는 방법을 정의합니다. 예를 들어 데이터 값의 첫 번째 문자가 대문자인지 확인하기 위해 conversion을 지정할 수 있습니다.

일부 통합에서는 매핑에 조건부 처리를 추가하는 것이 유용합니다. 예를 들어 소스 zip 코드 필드를 대상 zip 코드 필드에 매핑한다고 가정합니다. 소스 zip 코드 필드가 비어 있으면 대상 필드를 99999 로 채울 수 있습니다. 이렇게 하려면 zip 코드 소스 필드를 테스트하여 비어 있는지 확인하는 표현식을 지정하고, 비어 있으면 zip 코드 대상 필드에 99999 를 삽입합니다.

데이터 매퍼는 Microsoft excel 표현식과 유사하지만 모든 Microsoft excel 표현식 구문을 지원하지는 않는 표현식을 지원합니다. 이번 릴리스에서는 조건부 표현식에서 컬렉션 필드를 참조할 수 없습니다. 이는 향후 릴리스에서 변경될 것으로 예상됩니다.

각 매핑에 대해 0 또는 하나의 조건을 정의할 수 있습니다.

다음 절차에서는 매핑에 조건을 적용하여 시작됩니다. 매핑 및 조건으로 작업할 때 가장 편리한 순서대로 필요한 단계를 수행할 수 있습니다.

데이터 매퍼 단계를 추가하거나 편집하는 동안 이 단계에서 이미 정의된 매핑을 볼 수 있습니다. 이를 통해 올바른 매핑이 있는지 확인할 수 있습니다.

다음 표에서는 사용 가능한 변환을 설명합니다. 날짜 및 숫자 유형은 일반적으로 이러한 개념의 다양한 형태를 나타냅니다. 즉, number는 정수,long,double 을 포함합니다. 날짜는 예를 들어 날짜 ,시간, ZonedDateTime 이 포함됩니다.Date includes, for example, date, time,ZonedDateTime.

여러 소스 필드 또는 컬렉션과 같은 여러 값을 포함하는 소스 필드의 값에 적용할 수 있는 몇 가지 변환이 있습니다. 데이터 매퍼는 변환 결과를 대상 필드에 삽입합니다. 다음 표에서는 이러한 다중 복제 변환을 설명합니다.

이미 매핑된 필드에 영향을 미치는 데이터 모양 변경으로 인해 데이터 매퍼가 문서를 로드하지 못할 수 있습니다. 이 경우 영향을 받는 필드를 매핑하는 데이터 매퍼 단계를 편집하려고 하면 데이터 매퍼에서 소스 및 대상 패널을 표시할 수 없습니다. 대신 문서를 로드하거나 찾을 수 없음을 나타내는 오류가 표시됩니다. 오류 메시지는 다음 메시지 중 하나와 같습니다.

이 데이터 매퍼 단계를 삭제하고 업데이트된 필드를 매핑하는 새 데이터 매퍼 단계로 교체해야 합니다.

매핑된 필드를 데이터 모양을 변경하려면 항상 매핑을 다시 실행해야 하지만 데이터 매퍼 단계를 삭제하고 제거할 필요는 없습니다. 예를 들어 XML 인스턴스가 입력 데이터 모양을 지정하고 요소의 이름을 변경하는 경우 데이터 매퍼는 이전 필드 이름에 있는 매핑을 제거합니다.For example, if an XML instance specifies an input data shape and you change the name of an element, the data mapper removes the mapping that was to/from the old field name. 업데이트된 이름으로 필드에 매핑하기만 하면 됩니다.

매핑된 필드의 데이터 모양을 다음과 같은 방법으로 변경할 수 있습니다.

통합을 생성하고 게시한 후 통합 기능을 업데이트할 수 있습니다. 게시된 통합 초안을 편집한 다음 실행 중인 버전을 업데이트된 버전으로 교체할 수 있습니다. 이를 용이하게 하기 위해 각 통합을 위해 Fuse Online은 여러 버전과 각 버전의 상태를 유지 관리합니다. 통합 버전 및 상태를 이해하면 통합을 관리하는 데 도움이 됩니다.

Fuse Online에서는 새 버전의 통합을 실행할 때마다 새 버전 번호를 할당합니다. 예를 들어, twitter를 Cryostat 샘플 통합에 게시한다고 가정해 보겠습니다. 실행 후 다른 계정을 사용하여 Twitter에 연결하도록 통합을 업데이트합니다. 그런 다음 업데이트된 통합을 게시합니다. Fuse Online은 실행 중인 통합 버전을 중지하고 증가된 버전 번호와 업데이트된 버전의 통합을 게시합니다.

실행 중인 초기 통합은 버전 1입니다. 현재 실행 중인 업데이트된 통합은 버전 2입니다. 예를 들어 버전 2를 편집하여 Cryostat에 연결하는 데 다른 계정을 사용하고 해당 버전을 게시하면 통합의 버전 3이 됩니다.

정확히 하나의 통합 버전이 있을 수 있습니다. Fuse Online에는 통합 초안 버전에 대한 정의가 있지만 이 통합 버전을 실행하지는 않습니다. 통합 버전 초안에는 숫자가 없습니다. 통합을 편집하면 통합 초안을 업데이트하고 있습니다.

Fuse Online에서는 통합의 요약 페이지에서 통합 버전 목록을 볼 수 있습니다. 이 페이지를 보려면 왼쪽 탐색 패널에서 통합을 클릭합니다. 관심 있는 통합 항목에서 보기를 클릭합니다.

통합을 생성한 후 초안으로 저장하거나 게시하여 실행을 시작할 수 있습니다. 통합을 게시하면 Fuse Online에서 필요한 리소스를 어셈블하고, 통합 런타임을 빌드하고, 통합을 실행할 OpenShift 포드를 배포한 다음 통합 실행을 시작합니다.

언제든지 버튼을 클릭하여 통합 실행을 중지할 수 있습니다. 통합을 다시 시작하려는 경우 Fuse Online에는 이미 필요한 사항이 있으므로 처음 실행하는 데 게시한 시간보다 시간이 단축되었습니다.

처음으로 통합 버전을 시작하는 프로세스를 통합 게시라고 합니다. 다음 주제에서는 세부 정보를 제공합니다.

통합 실행을 위해 흐름의 각 단계에 대해 Fuse Online에서는 다음과 같은 활동 정보를 제공합니다.

Fuse Online에서 이 정보를 보려면 통합 요약을 표시한 다음 활동 탭을 클릭합니다.

통합 실행에 대한 자세한 정보를 얻으려면 통합 흐름에 로그 단계를 추가하여 통합 프로세스에서 처리하는 메시지에 대한 정보를 기록할 수 있습니다. 통합이 수신하는 각 메시지에 대해 로그 단계는 다음 중 하나 이상을 제공할 수 있습니다.

Fuse Online에서는 통합 실행을 모니터링할 수 있는 다양한 방법을 제공합니다. 다음 내용을 참조하십시오.

통합을 생성하고 Fuse Online 개발 환경에서 올바르게 실행되고 있으면 다른 Fuse Online 환경에서 테스트하려는 경우가 있습니다.

통합이 중지되면 해당 활동 및 기록 세부 정보를 확인합니다. 통합 활동 정보 보기 및 통합 기록 보기를 참조하십시오.

OAuth를 사용하는 애플리케이션에 대한 연결의 경우 애플리케이션의 액세스 토큰이 만료되었음을 나타내는 오류 메시지가 표시될 수 있습니다. 경우에 따라 덜 명시적 403 - Access denied 메시지가 표시될 수 있습니다. 메시지의 정보는 통합이 연결 중인 애플리케이션에 따라 달라집니다. 이 경우 애플리케이션에 다시 연결한 다음 통합을 다시 게시하십시오.

재연결이 성공하지 못하면 다음을 시도합니다.

통합을 생성한 후 단계를 추가, 편집 또는 제거하기 위해 이를 업데이트해야 할 수 있습니다.

통합을 삭제한 후에도 Fuse Online은 여전히 통합 기록을 유지합니다. 삭제된 통합 버전을 가져오는 경우 Fuse Online은 삭제된 통합 기록을 가져온 통합과 연결합니다.

개발, 스테이징 및 프로덕션 환경 전체에서 통합을 실행하려면 통합을 내보내고 가져올 수 있습니다. 환경은 모두 단일 OpenShift 클러스터에 있거나 여러 OpenShift 클러스터에 분산될 수 있습니다.

여기에 설명된 절차에서는 Fuse Online 콘솔에서 통합을 내보내고 가져오도록 지시합니다.

OpenShift Container Platform 온사이트에서 Fuse Online을 실행하는 경우 특정 통합을 내보내고 가져와야 하는 CI/CD(Continuous Integration/Continuous Deployment) 파이프라인이 있을 수 있습니다. 이 작업에 대한 자세한 내용은 외부 툴을 사용하여 CI/CD의 통합을 내보내거나 가져오기 를 참조하십시오.

다음 항목을 참조하십시오.

Fuse Online은 HTTP(Hypertext Transfer Protocol)를 지원하는 REST API(Representational State Transfer Application Programming Interface)용 커넥터를 생성할 수 있습니다. 이를 위해 Fuse Online에는 연결하려는 REST API를 설명하는 유효한 OpenAPI 2.0 문서가 필요합니다. API 서비스 공급자가 OpenAPI 문서를 사용할 수 없도록 하는 경우 숙련된 개발자가 OpenAPI 문서를 생성해야 합니다.

다음 항목에서는 REST API 커넥터 개발을 위한 정보와 지침을 제공합니다.

securityDefinitions:
  OauthSecurity:
    type: oauth2
    flow: accessCode
    authorizationUrl: 'https://oauth.simple.api/authorization'
    tokenUrl: 'https://oauth.simple.api/token'

securityDefinitions:
  concur_oauth2:
    type: 'oauth2'
    flow: 'accessCode'
    authorizationUrl: 'https://example.com/oauth/authorize'
    tokenUrl: 'https://example.com/oauth/token'
    scopes:
      LIST: Access List API
    x-authorize-using-parameters: true

securityDefinitions:
  concur_oauth2:
    type: 'oauth2'
    flow: 'accessCode'
    authorizationUrl: 'https://example.com/oauth/authorize'
    tokenUrl: 'https://example.com/oauth/token'
    scopes:
      LIST: Access List API
    x-refresh-token-retry-statuses: 401,402,403

Fuse Online에서는 OpenAPI 문서에서 REST API 클라이언트 커넥터를 생성할 수 있습니다. OpenAPI 문서의 콘텐츠에 대한 자세한 내용은 REST API 클라이언트 커넥터 개발을 참조하십시오.

다음 항목에서는 REST API 클라이언트 커넥터를 추가 및 관리하기 위한 정보와 지침을 제공합니다.

REST API 클라이언트 커넥터를 생성한 후 해당 커넥터 사용에 대한 자세한 내용은 Fuse Online을 애플리케이션 및 서비스에 연결, REST API에 연결을 참조하십시오.

Fuse Online에서 통합을 생성하는 데 필요한 기능을 제공하지 않으면 전문가 개발자가 필요한 동작을 제공하는 확장을 코딩할 수 있습니다. 통합 확장 리포지토리 https://github.com/syndesisio/syndesis-extensions 에는 확장의 예가 포함되어 있습니다.

비즈니스 통합자는 확장을 코딩하는 개발자와 요구 사항을 공유합니다. 개발자는 확장자가 포함된 .jar 파일을 제공합니다. 비즈니스 통합자는 Fuse Online에서 .jar 파일을 업로드하여 사용자 지정 커넥터, 사용자 지정 단계 또는 Fuse Online에서 사용할 수 있는 라이브러리 리소스를 만듭니다.

Red Hat Developer Studio의 Fuse Tooling 플러그인은 단계 확장 또는 커넥터 확장을 개발하는 데 도움이 되는 마법사를 제공합니다. Developer Studio에서 단계 확장 또는 커넥터 확장을 개발하도록 선택하는 경우 또는 다른 IDE에서 개인 기본 설정의 문제입니다. Developer Studio 플러그인 사용에 대한 자세한 내용은 Fuse Online 통합을 위한 확장 개발을 참조하십시오.

이 문서에서는 다음 항목에서는 절차를 간략하게 설명하고 요구 사항을 설명하고 선택한 IDE에서 확장 기능을 개발하기 위한 추가 예제를 제공합니다.

extension.jar
|
+- META-INF
|  |
|  +- syndesis
|     |
|     +- syndesis-extension-definition.json 1
|
+- mycompany
|  |
|  +-project
|    |
|    +-YourClasses.class 2
|
+- lib 3
  |
  +-dependency1.jar
  |
  +-dependency2.jar

{
  "schemaVersion": "v1",
  "name": "",
  "description": "",
  "version": "",
  "extensionId": "",
  "extensionType": "",
  "properties": {
  },
  "actions": [
  ],
  "dependencies": [
  ],
}

"properties": {
   "hostname": {
     "description": "IRC Server hostname",
     "displayName": "Hostname",
     "labelHint": "Hostname of the IRC server to connect to",
     "order": "1",
     "required": true,
     "secret": false,
     "type": "string"
   },
   "password": {
     "description": "IRC Server password",
     "displayName": "Password",
     "labelHint": "Required if IRC server requires it to join",
     "order": "3",
     "required": false,
     "secret": true,
     "type": "string"
   },
   "port": {
     "description": "IRC Server port",
     "displayName": "Port",
     "labelHint": "Port of the IRC server to connect to",
     "order": "2",
     "required": true,
     "secret": false,
     "tags": [],
     "type": "int"
   }
 },

"actions": [
   {
      ...

      "propertyDefinitionSteps": [
         {
            ...

            "properties":
               {
                  "control-ONE": {
                     "type": "string",
                     "displayName": "Topic Name",
                     "order": "2",
                     ...,
                     }

                  "control-TWO": {
                     "type": "boolean",
                     "displayName": "Urgent",
                     "order": "3",
                     ...
                     }

                  "control-THREE": {
                     "type": "textarea",
                     "displayName": "Comment",
                     "order": "1",
                     ...,
                     }
 } } ]

public class LogAction extends RouteBuilder {
    @ConfigurationProperty(
        name = "prefix",
        description = "The Log body prefix message",
        displayName = "Log Prefix",
        type = "string")

@Action(id = "split", name = "Split", description = "Split your exchange")
public class SplitAction implements Step {

    @ConfigurationProperty(
        name = "language",
        displayName = "Language",
        description = "The language used for the expression")
    private String language;

    @ConfigurationProperty(
        name = "expression",
        displayName = "Expression",
        description = "The expression used to split the exchange
     private String language;

<plugin>
    <groupId>io.syndesis.extension</groupId>
    <artifactId>extension-maven-plugin</artifactId>
    <version>${syndesis.version}</version>
    <executions>
        <execution>
        <goals>
            <goal>generate-metadata</goal>
            <goal>repackage-extension</goal>
        </goals>
        </execution>
    </executions>
</plugin>

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">

  <modelVersion>4.0.0</modelVersion>
  <groupId>com.company</groupId>
  <artifactId>my-extension</artifactId>
  <version>1.0.0</version>
  <name>MyExtension</name>
  <description>A Sample Extension</description>
  <packaging>jar</packaging>

  <dependencyManagement>
    <dependencies>
      <dependency>
        <groupId>io.syndesis.extension</groupId>
        <artifactId>extension-bom</artifactId>
        <version>1.3.10</version>
        <type>pom</type>
        <scope>import</scope>
      </dependency>
    </dependencies>
  </dependencyManagement>

  <dependencies>
    <dependency>
      <groupId>io.syndesis.extension</groupId>
      <artifactId>extension-api</artifactId>
      <scope>provided</scope>
    </dependency>
    <dependency>
      <groupId>com.github.lalyos</groupId>
      <artifactId>jfiglet</artifactId>
      <version>0.0.8</version>
    </dependency>
  </dependencies>

  <build>
    <plugins>
      <plugin>
        <groupId>org.apache.maven.plugins</groupId>
        <artifactId>maven-compiler-plugin</artifactId>
        <version>3.7.0</version>
        <configuration>
          <source>1.8</source>
          <target>1.8</target>
        </configuration>
      </plugin>
      <plugin>
        <groupId>io.syndesis.extension</groupId>
        <artifactId>extension-maven-plugin</artifactId>
        <version>1.3.10</version>
        <executions>
          <execution>
            <goals>
              <goal>generate-metadata</goal>
              <goal>repackage-extension</goal>
            </goals>
          </execution>
        </executions>
      </plugin>
    </plugins>
  </build>
</project>

{
  "name": "MyExtension",
  "description": "A Sample Extension",
  "extensionId": "com.company:my-extension",
  "version": "1.0.0",
  "dependencies": [ {
    "type": "MAVEN",
    "id": "io.syndesis.extension:extension-api:jar:1.3.10"
  } ],
  "extensionType": "Libraries",
  "schemaVersion": "v1"
}

my-extension-1.0.0.jar
|
+- lib
|  |
|  + jfiglet-0.0.8.jar
|
+- META-INF
  |
  +- MANIFEST.MF
     |
     +- syndesis
        |
        +- syndesis-extension-definition.json

"outputDataShape": {
     "kind": "java",
     "type": "org.apache.camel.component.telegram.model.IncomingMessage"
},

<dependency>
  <groupId>io.syndesis.extension</groupId>
  <artifactId>extension-annotation-processor</artifactId>
  <optional>true</optional>
</dependency>

<?xml version="1.0" encoding="UTF-8"?>
<routes xmlns="http://camel.apache.org/schema/spring"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="
      http://camel.apache.org/schema/spring
      http://camel.apache.org/schema/spring/camel-spring.xsd">

  <route id="log-body-with-prefix">
    <from uri="direct:log"/>
    <choice>
      <when>
        <simple>${header.prefix} != ''</simple>
        <log message="${header.prefix} ${body}"/>
      </when>
      <otherwise>
        <log message="Output ${body}"/>
      </otherwise>
    </choice>
  </route>

</routes>

{
  "actionType": "step",
  "id": "log-body-with-prefix",
  "name": "Log body with prefix",
  "description": "A simple body log with a prefix",
  "descriptor": {
    "kind": "ENDPOINT", 1
    "entrypoint": "direct:log", 2
    "resource": "classpath:log-body-action.xml", 3
    "inputDataShape": {
      "kind": "none"
    },
    "outputDataShape": {
      "kind": "none"
    },
  "propertyDefinitionSteps": [ {
    "description": "extension-properties",
    "name": "extension-properties",
    "properties": { 4
      "prefix": {
        "componentProperty": false,
        "deprecated": false,
        "description": "The Log body prefix message",
        "displayName": "Log Prefix",
        "javaType": "String",
        "kind": "parameter",
        "required": false,
        "secret": false,
        "type": "string"
      }
    }
  } ]
  }
}

import org.apache.camel.builder.RouteBuilder;

import io.syndesis.extension.api.annotations.Action;
import io.syndesis.extension.api.annotations.ConfigurationProperty;

@Action( 1
    id = "log-body-with-prefix",
    name = "Log body with prefix",
    description = "A simple body log with a prefix",
    entrypoint = "direct:log")
public class LogAction extends RouteBuilder {
    @ConfigurationProperty( 2
        name = "prefix",
        description = "The Log body prefix message",
        displayName = "Log Prefix",
        type = "string")
    private String prefix;

    @Override
    public void configure() throws Exception {
        from("direct::start") 3
            .choice()
                .when(simple("${header.prefix} != ''"))
                    .log("${header.prefix} ${body}")
                .otherwise()
                    .log("Output ${body}")
            .endChoice();
    }
}

{
  "id": "log-body-with-prefix",
  "name": "Log body with prefix",
  "description": "A simple body log with a prefix",
  "descriptor": {
    "kind": "ENDPOINT", 1
    "entrypoint": "direct:log", 2
    "resource": "class:io.syndesis.extension.log.LogAction", 3
    "inputDataShape": {
      "kind": "none"
    },
    "outputDataShape": {
      "kind": "none"
    },
    "propertyDefinitionSteps": [ {
      "description": "extension-properties",
      "name": "extension-properties",
      "properties": { 4
        "prefix": {
          "componentProperty": false,
          "deprecated": false,
          "description": "The Log body prefix message",
          "displayName": "Log Prefix",
          "javaType": "java.lang.String",
          "kind": "parameter",
          "required": false,
          "secret": false,
          "type": "string",
          "raw": false
        }
      }
    } ]
  },
  "actionType": "step"
}

import io.syndesis.extension.api.annotations.Action;
import io.syndesis.extension.api.annotations.ConfigurationProperty;
import org.apache.camel.builder.RouteBuilder;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class ActionsConfiguration {

    @Action( 1
        id = "log-body-with-prefix",
        name = "Log body with prefix",
        description = "A simple body log with a prefix",
        entrypoint = "direct:log")
    @ConfigurationProperty( 2
        name = "prefix",
        description = "The Log body prefix message",
        displayName = "Log Prefix",
        type = "string")
    @Bean 3
    public RouteBuilder logBodyWithprefix() {
        return new RouteBuilder() {
            @Override
            public void configure() throws Exception {
                from("direct::start") 4
                    .choice()
                        .when(simple("${header.prefix} != ''"))
                            .log("${header.prefix} ${body}")
                        .otherwise()
                            .log("Output ${body}")
                    .endChoice();
             }
        };
    }
}

{
  "id": "log-body-with-prefix",
  "name": "Log body with prefix",
  "description": "A simple body log with a prefix",
  "descriptor": {
    "kind": "ENDPOINT", 1
    "entrypoint": "direct:log", 2
    "inputDataShape": {
      "kind": "none"
    },
    "outputDataShape": {
      "kind": "none"
    },
    "propertyDefinitionSteps": [ {
      "description": "extension-properties",
      "name": "extension-properties",
      "properties": { 3
        "prefix": {
          "componentProperty": false,
          "deprecated": false,
          "description": "The Log body prefix message",
          "displayName": "Log Prefix",
          "javaType": "java.lang.String",
          "kind": "parameter",
          "required": false,
          "secret": false,
          "type": "string",
          "raw": false
        }
      }
    } ]
  },
  "actionType": "step"
}

import org.apache.camel.Body;
import org.apache.camel.Handler;
import org.apache.camel.Header;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import io.syndesis.extension.api.annotations.Action;
import io.syndesis.extension.api.annotations.ConfigurationProperty;

@Action(
    id = "log-body-with-prefix",
    name = "Log body with prefix",
    description = "A simple body log with a prefix")
public class LogAction  {
    private static final Logger LOGGER = LoggerFactory.getLogger(LogAction.class);

    @ConfigurationProperty(
        name = "prefix",
        description = "The Log body prefix message",
        displayName = "Log Prefix",
        type = "string")
    private String prefix;

    @Handler 1
    public void process(@Header("prefix") String prefix, @Body Object body) {
        if (prefix == null) {
            LOGGER.info("Output {}", body);
        } else {
            LOGGER.info("{} {}", prefix, body);
        }
    }
}

{
  "id": "log-body-with-prefix",
  "name": "Log body with prefix",
  "description": "A simple body log with a prefix",
  "descriptor": {
    "kind": "BEAN", 1
    "entrypoint": "io.syndesis.extension.log.LogAction::process", 2
    "inputDataShape": {
      "kind": "none"
    },
    "outputDataShape": {
      "kind": "none"
    },
    "propertyDefinitionSteps": [ {
      "description": "extension-properties",
      "name": "extension-properties",
      "properties": {
        "prefix": { 3
          "componentProperty": false,
          "deprecated": false,
          "description": "The Log body prefix message",
          "displayName": "Log Prefix",
          "javaType": "java.lang.String",
          "kind": "parameter",
          "required": false,
          "secret": false,
          "type": "string",
          "raw": false
        }
      }
    } ]
  },
  "actionType": "step"
}

import org.apache.camel.Body;
import org.apache.camel.Handler;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import io.syndesis.extension.api.annotations.Action;
import io.syndesis.extension.api.annotations.ConfigurationProperty;

@Action(
    id = "log-body-with-prefix",
    name = "Log body with prefix",
    description = "A simple body log with a prefix")
public class LogAction  {
    private static final Logger LOGGER = LoggerFactory.getLogger(LogAction.class);

    @ConfigurationProperty(
        name = "prefix",
        description = "The Log body prefix message",
        displayName = "Log Prefix",
        type = "string")
    private String prefix;

    public void setPrefix(String prefix) { 1
        this.prefix = prefix;
    }

    public String getPrefix() { 2
        return prefix;
    }

    @Handler
    public void process(@Body Object body) {
        if (this.prefix == null) {
            LOGGER.info("Output {}", body);
        } else {
            LOGGER.info("{} {}", this.prefix, body);
        }
    }
}

import java.util.Map;
import java.util.Optional;

import io.syndesis.extension.api.Step;
import io.syndesis.extension.api.annotations.Action;
import io.syndesis.extension.api.annotations.ConfigurationProperty;
import org.apache.camel.CamelContext;
import org.apache.camel.model.ProcessorDefinition;
import org.apache.camel.util.ObjectHelper;
import org.apache.camel.Expression;
import org.apache.camel.builder.Builder;
import org.apache.camel.processor.aggregate.AggregationStrategy;
import org.apache.camel.processor.aggregate.UseOriginalAggregationStrategy;
import org.apache.camel.spi.Language;

@Action(id = "split", name = "Split", description = "Split your exchange")
public class SplitAction implements Step {

    @ConfigurationProperty(
        name = "language",
        displayName = "Language",
        description = "The language used for the expression")
    private String language;

    @ConfigurationProperty(
        name = "expression",
        displayName = "Expression",
        description = "The expression used to split the exchange")
    private String expression;

    public String getLanguage() {
        return language;
    }

    public void setLanguage(String language) {
        this.language = language;
    }

    public String getExpression() {
        return expression;
    }

    public void setExpression(String expression) {
        this.expression = expression;
    }

    @Override
    public Optional<ProcessorDefinition> configure(
            CamelContext context,
            ProcessorDefinition route,
            Map<String, Object> parameters) { 1

        String languageName = language;
        String expressionDefinition = expression;

        if (ObjectHelper.isEmpty(languageName) && ObjectHelper.isEmpty(expressionDefinition)) {
            route = route.split(Builder.body());
        } else if (ObjectHelper.isNotEmpty(expressionDefinition)) {

            if (ObjectHelper.isEmpty(languageName)) {
                languageName = "simple";
            }

            final Language splitLanguage = context.resolveLanguage(languageName);
            final Expression splitExpression = splitLanguage.createExpression(expressionDefinition);
            final AggregationStrategy aggreationStrategy = new UseOriginalAggregationStrategy(null, false);

            route = route.split(splitExpression).aggregationStrategy(aggreationStrategy);
        }

        return Optional.of(route);
    }
}

{
  "id": "split",
  "name": "Split",
  "description": "Split your exchange",
  "descriptor": {
    "kind": "STEP", 1
    "entrypoint": "io.syndesis.extension.split.SplitAction", 2
    "inputDataShape": {
      "kind": "none"
    },
    "outputDataShape": {
      "kind": "none"
    },
    "propertyDefinitionSteps": [ {
      "description": "extension-properties",
      "name": "extension-properties",
      "properties": {
        "language": {
          "componentProperty": false,
          "deprecated": false,
          "description": "The language used for the expression",
          "displayName": "Language",
          "javaType": "java.lang.String",
          "kind": "parameter",
          "required": false,
          "secret": false,
          "type": "string",
          "raw": false
        },
        "expression": {
          "componentProperty": false,
          "deprecated": false,
          "description": "The expression used to split the exchange",
          "displayName": "Expression",
          "javaType": "java.lang.String",
          "kind": "parameter",
          "required": false,
          "secret": false,
          "type": "string",
          "raw": false
        }
      }
    } ]
  },
  "tags": [],
  "actionType": "step"
}

public class DataSourceCustomizer implements ComponentProxyCustomizer, CamelContextAware {
    private final static Logger LOGGER = LoggerFactory.getLogger(DataSourceCustomizer.class);

    private CamelContext camelContext;

    @Override
    public void setCamelContext(CamelContext camelContext) { 1
        this.camelContext = camelContext;
    }

    @Override
    public CamelContext getCamelContext() { 2
        return this.camelContext;
    }

    @Override
    public void customize(ComponentProxyComponent component, Map<String, Object> options) {
        if (!options.containsKey("dataSource")) {
            if (options.containsKey("user") && options.containsKey("password") && options.containsKey("url")) {
                try {
                    BasicDataSource ds = new BasicDataSource();

                    consumeOption(camelContext, options, "user", String.class, ds::setUsername); 3
                    consumeOption(camelContext, options, "password", String.class, ds::setPassword); 4
                    consumeOption(camelContext, options, "url", String.class, ds::setUrl); 5

                    options.put("dataSource", ds);
                } catch (@SuppressWarnings("PMD.AvoidCatchingGenericException") Exception e) {
                    throw new IllegalArgumentException(e);
                }
            } else {
                LOGGER.debug("Not enough information provided to set-up the DataSource");
            }
        }
    }
}

public class DataSourceCustomizer implements ComponentProxyCustomizer, CamelContextAware {
    private final static Logger LOGGER = LoggerFactory.getLogger(DataSourceCustomizer.class);

    private CamelContext camelContext;
    private String userName;
    private String password;
    private String url;

    @Override
    public void setCamelContext(CamelContext camelContext) { 1
        this.camelContext = camelContext;
    }

    @Override
    public CamelContext getCamelContext() { 2
        return this.camelContext;
    }

    public void setUserName(String userName) { 3
      this.userName = userName;
    }

    public String getUserName() { 4
      return this.userName;
    }

    public void setPassword(String password) { 5
      this.password = password;
    }

    public String getPassword() { 6
      return this.password;
    }

    public void setUrl(String url) { 7
      this.url = url;
    }

    public String getUrl() { 8
      return this.url;
    }

    @Override
    public void customize(ComponentProxyComponent component, Map<String, Object> options) {
        if (!options.containsKey("dataSource")) {
            if (userName != null && password != null && url != null) {
                try {
                    BasicDataSource ds = new BasicDataSource();
                    ds.setUserName(userName);
                    ds.setPassword(password);
                    ds.setUrl(url);

                    options.put("dataSource", ds);
                } catch (@SuppressWarnings("PMD.AvoidCatchingGenericException") Exception e) {
                    throw new IllegalArgumentException(e);
                }
            } else {
                LOGGER.debug("Not enough information provided to set-up the DataSource");
            }
        }
    }
}

public class AWSS3DeleteObjectCustomizer implements ComponentProxyCustomizer {
  	private String filenameKey;

    public void setFilenameKey(String filenameKey) {
      this.filenameKey = filenameKey;
    }

    public String getFilenameKey() {
        return this.filenameKey;
    }

    @Override
    public void customize(ComponentProxyComponent component, Map<String, Object> options) {
      	component.setBeforeProducer(this::beforeProducer);
    }

    public void beforeProducer(final Exchange exchange) throws IOException {
      	exchange.getIn().setHeader(S3Constants.S3_OPERATION, S3Operations.deleteObject);

    	  if (filenameKey != null) {
    		    exchange.getIn().setHeader(S3Constants.KEY, filenameKey);
    	  }
    }
}

{
  "schemaVersion" : "v1",
  "name" : "Example JDBC Driver Library",
  "description" : "Syndesis Extension for adding a custom JDBC Driver",
  "extensionId" : "io.syndesis.extensions:syndesis-library-jdbc-driver",
  "version" : "1.0.0",
  "tags" : [ "jdbc-driver" ],
  "extensionType" : "Libraries"
}

<dependency>
    <groupId>com.company</groupId>
    <artifactId>jdbc-driver</artifactId>
    <version>1.0</version>
    <scope>system</scope>
    <systemPath>${project.basedir}/lib/jdbc-driver-1.0.jar</systemPath>
</dependency>

확장을 통해 Fuse Online에 사용자 지정을 추가하여 원하는 방식으로 애플리케이션을 통합할 수 있습니다. 확장 프로그램에서 제공된 사용자 지정 사용을 시작한 후 해당 사용자 지정을 사용하는 통합을 식별할 수 있습니다. 이 기능은 확장 기능을 업데이트하거나 삭제하기 전에 수행하는 데 유용합니다.

다음 주제에서는 세부 정보를 제공합니다.