Oracle Integration 3を使用したKafkaトピックのOracle Autonomous Databaseへのストリーミングについて学習
Kafkaのトピックには様々なユースケースがあり、データは常に受信および処理される必要があります。Oracle Cloud Infrastructure (OCI)でストリーミングKafkaを消費するには、いくつかの方法があります。
このソリューション・プレイブックでは、Oracle Integration 3を使用して、Oracle GoldenGate Stream AnalyticsからKafkaストリーミング・メッセージを取得し、データをOracle Autonomous Databaseに格納します。Oracle GoldenGate Stream Analyticsを使用すると、ユーザーはスケーラブルなデータ変換および分析パイプラインを構築して、俊敏なリアルタイムのビジネス・インサイトを得ることができます。オンプレミス・インスタンスからKafkaストリームを使用することもできます。
アーキテクチャ
このアーキテクチャは、OCIリージョンのオンプレミスKafka Streams、Oracle Integration 3、Oracle GoldenGate Stream AnalyticsおよびOracle Autonomous Databaseを示しています。
このアーキテクチャを使用して、Oracle Integration 3を使用して、オンプレミスのKafkaストリームまたはOracle GoldenGate Stream AnalyticsからOracle Autonomous DatabaseにKafkaストリーミング・メッセージを取得します。
Oracle Integration 3を含むOCIリージョンは、オンプレミスのKafkaストリームまたはOracle GoldenGate Stream Analyticsからデータを取り込みます。
Oracle Integration 3は、Oracle Autonomous Databaseのリレーショナル表にデータを格納します。
このアーキテクチャでは、次のコンポーネントがサポートされています。
- Kafkaストリーム
Kafka Streamsは、入力および出力データがKafkaクラスタに格納されるアプリケーションおよびマイクロサービスを構築するためのクライアント・ライブラリです。クライアント側で標準のJavaおよびScalaアプリケーションを記述およびデプロイする簡略性と、Kafkaのサーバー側クラスタ・テクノロジのメリットを組み合せます。
- Autonomous Database
Oracle Autonomous Databaseは、トランザクション処理およびデータ・ウェアハウス・ワークロードに使用できる、完全に管理された事前構成済のデータベース環境です。ハードウェアの構成や管理、ソフトウェアのインストールを行う必要はありません。Oracle Cloud Infrastructureは、データベースの作成、バックアップ、パッチ適用、アップグレードおよびチューニングを処理します。
- Oracle Integration 3
Oracle Integration 3は、完全に管理された事前構成済の環境であり、クラウドおよびオンプレミス・アプリケーションの統合、ビジネス・プロセスの自動化、ビジュアル・アプリケーションの開発、SFTP準拠ファイル・サーバーを使用したファイルの格納および取得、およびB2B取引パートナとのビジネス・ドキュメントの交換が可能です。
- Oracle GoldenGateストリーム・アナリティクス
GoldenGate Stream Analyticsでは、Apache Sparkベースのシステムでイベント・ストリームのリアルタイム監視および分析を行えるカスタムの操作ダッシュボードを作成できます。これを使用することで、顧客は、Apache Sparkベース・システムでの対象となるイベントの特定、それらのイベント・ストリームに対する問合せのリアルタイムでの実行、操作ダッシュボードの実行、およびその分析に基づいたアラートの生成を行えるようになります。
- Oracle SQL Developer
Oracle SQL Developerは、フリーの統合開発環境で、従来のデプロイメントとクラウド・デプロイメントの両方におけるOracle Databaseの開発および管理を簡素化します。SQL Developerは、PL/SQLアプリケーションの完全なエンドツーエンド開発、問合せとスクリプトを実行するためのワークシート、データベースを管理するためのDBAコンソール、レポート・インタフェース、完全なデータ・モデリング・ソリューション、およびサード・パーティ・データベースをOracleに移行するための移行プラットフォームを提供します。
必要な製品およびロールについて
このソリューションには、次の製品およびロールが必要です。
- Oracle Autonomous Database
- Oracle Integration 3
- Oracle Cloud Infrastructure
- Oracle GoldenGateストリーム分析
各サービスに必要なロールは次のとおりです。
| 製品名: ロール | 必須... |
|---|---|
| Oracle Autonomous Database: 管理 | 資格証明を作成します。 |
| Oracle Integration 3: 管理 | 資格証明を作成します。 |
| Oracle Cloud Infrastructure: 管理 | OCIリソースを作成および管理します。 |
| Oracle GoldenGate Stream Analytics: 管理 | データを取り込むようにKafkaプロデューサを構成します。 |
必要なものを得るには、Oracle製品、ソリューションおよびサービスを参照してください。