1. Oracle Integration Generation 2スタート・ガイド
  2. レシピ・リファレンス
  3. エンタープライズ・メッセージング・レシピ
  4. Oracle Cloud Infrastructureストリーミング・サービスのパブリッシュおよびサブスクライブ
機械翻訳について

Oracle Cloud Infrastructureストリーミング・サービスの公開およびサブスクライブ

これらのレシピを使用して、Oracle Integrationから「Oracle Cloud Infrastructureストリーミング・サービス」にメッセージを送信し、「Oracle Cloud Infrastructureストリーミング・サービス」からメッセージを受信します。

ノート:

このレシピは、統合ストアで「Oracle Cloud Infrastructureストリーミング - 公開とサブスクライブ」として使用できます。 Oracleには、サンプルとしてのみこのレシピが用意されています。 レシピはガイダンスのみを目的としており、エラーがないことは保証されていません。 このレシピはサポートされていません。

概要

レシピ名 説明 構成必須
Oracle Cloud Infrastructureストリーミング - 公開

「Oracle Cloud Infrastructureストリーミング・サービス」とのこの統合はスケジュールによってトリガーされ、Oracle Integrationから指定されたストリーム・プールにメッセージがパブリッシュされます。

この統合の接続は、レシピOracle Cloud Infrastructure Streamingの接続と同じです - Subscribe.

レシピを使用するには:

  1. 前提条件を満たしていることを確認します。 「接続を作成するための前提条件」を参照してください。
  2. 「Oracle Cloud Infrastructureストリーミング・サービス」を指すように接続パラメータを構成します。 パラメータの構成方法の詳細は、「接続の作成」を参照してください。
    • ブートストラップ・サーバー
    • セキュリティ・ポリシー: SASL PLAIN Over SSL OSS
    • SASLユーザー名
    • SASLパスワード
    • TrustStore
    • エージェント・グループ(サービスがファイアウォールの背後にある需要場所でホストされている場合)
  3. 統合で、スケジュール定義を編集して、「Oracle Cloud Infrastructureストリーミング・サービス」からメッセージを取得する頻度を指定します。 スケジュール定義の編集方法の詳細は、「統合スケジュールの定義」を参照してください。
  4. 統合を編集し、「公開」エンドポイントを編集します。 メッセージの送信先のストリームおよびパーティションを指定し、メッセージ構造のサンプルが含まれていることを確認します。 統合には、置換する必要がある次のサンプル・メッセージ構造があります。 詳細は、「ストリームとパーティション・ページ」および「メッセージ構造ページ」を参照してください。 
    
{
   "Id" : “123”,   [ ns2:getFlowId () ]
   "Country":"US",
   "State": "MA" ,
   "County": "Worcester"
 }
  5. 統合をアクティブ化します。 手順については、「統合のアクティブ化」を参照してください。
  6. 統合を監視します。 統合を追跡し、アクティビティ・ストリームで送信されたメッセージを監視できます。 手順については、「アクティビティ・ストリームの表示」を参照してください。
Oracle Cloud Infrastructureストリーミング - サブスクライブ

この「Oracle Cloud Infrastructureストリーミング・サービス」との統合はスケジュールによってトリガーされ、指定されたストリーム・プールからのメッセージを消費します。

この統合の接続は、レシピOracle Cloud Infrastructure Streamingの接続と同じです - Publish.

レシピを使用するには:

  1. 前提条件を満たしていることを確認します。 「接続を作成するための前提条件」を参照してください。
  2. 「Oracle Cloud Infrastructureストリーミング・サービス」を指すように接続パラメータを構成します。 パラメータの構成方法の詳細は、「接続の作成」を参照してください。
    • ブートストラップ・サーバー
    • セキュリティ・ポリシー: SASL PLAIN Over SSL OSS
    • SASLユーザー名
    • SASLパスワード
    • TrustStore
    • エージェント・グループ(サービスがファイアウォールの背後にある需要場所でホストされている場合)
  3. 統合のスケジュール定義を編集して、「Oracle Cloud Infrastructureストリーミング・サービス」からメッセージを取得する頻度を指定します。 スケジュール定義の編集方法の詳細は、「統合スケジュールの定義」を参照してください。
  4. 統合をアクティブ化します。 手順については、「統合のアクティブ化」を参照してください。
  5. 統合を監視します。 統合を追跡し、アクティビティ・ストリームから消費されたメッセージを監視できます。 手順については、「アクティビティ・ストリームの表示」を参照してください。
    アクティビティ・ストリームの例を次に示します:
    
<?xml version="1.0" encoding="UTF-8"?>
<ConsumeResponse xmlns="http://xmlns.oracle.com/cloud/adapter/ocistreaming/ConsumeFrom_REQUEST/types">
  <MessageOutCollection xmlns="http://xmlns.oracle.com/cloud/adapter/kafka/types" xmlns:NS1="http://xmlns.oracle.com/cloud/adapter/kafka/types" NS1:status="SUCCESS">
     <Message>
	<headers/>
	<request-wrapper>
	  <content xmlns="http://xmlns.oracle.com/cloud/adapter/ocistreaming/ConsumeFrom/types">
	     <Id>7.2803233E7</Id>	     
            <Country>US</Country>
	     <State>MA</State>
	     <county>Worcester</county>
	  </content>
	</request-wrapper>
	<config-parameters>
	  <partition>0</partition>
	  <offset>25</offset>
	</config-parameters>
	<error-details/>
	<status>SUCCESS</status>
    </Message>
  </MessageOutCollection>
</ConsumeResponse>

システムおよびアクセスの要件

  • Oracle Integration

  • Oracle Cloud Infrastructureストリーミング・サービス

レシピのインストール、構成および実行

レシピのインストール、構成および実行の詳細は、「統合アクセラレータおよびレシピの開始」を参照してください。

関連ドキュメント