Stream Analyticsについて
OCI GoldenGate Stream分析を使用して、イベント・ストリームのリアルタイム監視および分析を提供するカスタム運用ダッシュボードを作成します。対象となるイベントを特定し、リアルタイムでイベント・ストリームに対して問合せを実行するか、分析に基づいてアラートを生成します。
ストリーム分析の概念
OCI GoldenGate Stream Analyticsを使用するには、次の概念が不可欠です。
- 接続: ソース・テクノロジまたはターゲット・テクノロジの接続情報を格納します。
- ストリーム: 動的データの連続フロー。
- パイプライン: ソースからターゲットへのワークフロー・データ。
- ビジネス・ロジック: パイプラインに適用して、分析する正確なデータを取得できる様々なフィルタおよび関数。
- 公開: パイプラインをすべてのStream分析ユーザーが使用できるようにし、データをターゲットに送信します。
Stream Analyticsのサポートと制限
OCI GoldenGate Stream AnalyticsはGoldenGate Stream Analytics (GGSA)と同じように見えますが、OCIバージョンでのみ使用可能な特定の機能や、OCIバージョンでサポートされていないその他の機能があります。
OCI固有の制限
- カスタムJarは、OCI GoldenGate Stream Analyticsではサポートされていません。
- OCI GoldenGate Stream Analyticsには、ユーザーがアクセスできるKafkaクラスタは含まれていません。GoldenGate変更データ入力の使用を含むKafkaの入力または出力の場合、OCIストリーミングなどの個別のKafkaデプロイメントが必要です。
OCI GoldenGate Stream Analyticsで機能がサポートされているかどうかを知らせるGoldenGate Stream Analyticsのノートに注意してください。
サポートされている接続
OCI GoldenGate Stream Analyticsでサポートされている接続のタイプについて学習します。
OCI GoldenGate Stream Analyticsでは、次のソース・テクノロジ・タイプがサポートされます:
- Oracle Autonomous Database
- Oracle Database
- OCIストリーミング
- OCI MySQLデータベース・サービス
- Apache Kafka
- 豊かなKafka
- Oracle GoldenGateサーバー
Coherence、IgniteおよびJava Message Server (JMS)接続は、ストリーム分析コンソール内で直接作成することもできます。
Stream Analyticsでは、次のターゲット・テクノロジ・タイプがサポートされています:
Amazon S3、Azure Data Lake Storage、Coherence、Hadoop File Storage (HDFS)、Ignite、JMSおよびMongoDB接続をStream Analyticsコンソール内で直接作成することもできます。
Stream Analyticsデプロイメントのサイズ設定に関する考慮事項
Oracle Compute Unit (OCPU)の選択およびスケーリングに関するOCI GoldenGateデプロイメントの測定および請求の情報を確認してください。
OCI GoldenGate Stream AnalyticsのOCPU使用率は、次の要因に基づいて計算されます。
- Stream Analyticsコンソール
- ストリーミング・パイプラインの数
- Igniteクラスタ
- GoldenGateビッグ・データ・クラスタ
必要なOCPUの数を計算する前に、まず各Stream Analyticsリソースに必要なコンピュート・ユニットの数を確認します。1 OCPUは2コンピュート・ユニット(vCPUs)と等しくなります。1 vCPUは1000ミリコア(1000m)です。
| パイプライン | ドライバ | 実行方法 | 合計vCPUs | 請求済OCPU |
|---|---|---|---|---|
| パイプラインA | 500m | 1 x 500m | 1000m | 1 |
| パイプラインB | 500m | 2 x 500m | 1500m | 1 |
| パイプラインC | 500m | 4 x 500m | 2500m | 2 |
| パイプラインD | 600m | 2 x 700m | 2000m | 1 |
| パイプラインE | 1000m | 2 x 1000m | 3000m | 2 |
ストリーム分析コンソールで、パイプラインごとに必要に応じてドライバおよびエグゼキュータの設定を構成できます。
次の表に、パイプラインの数(上の表)および必要なOCPUの計算数に基づくStream Analyticsリソース構成の例を示します。
| Stream Analyticsコンソール | パイプライン数 | ストリーミング・パイプライン | Igniteクラスタ | GoldenGate: ビッグ・データ・クラスタ用 | 請求済OCPU |
|---|---|---|---|---|---|
| 1000m | 1 xパイプラインA | 1000m | 0 | 0 | 1 |
| 1000m | 3 xパイプラインA | 3000m | 0 | 0 | 2 |
| 1000m | 1 xパイプラインB | 1500m | 0 | 0 | 2 |
| 1000m | 1 xパイプラインB | 1500m | 2 x 500m | 500m | 2 |
| 1000m | 1 xパイプラインA
1 xパイプラインB |
2500m | 2 x 500m | 500m | 3 |
| 1000m | 2 xパイプラインA
1 xパイプラインB |
3500m | 2 x 500m | 500m | 3 |
Stream Analyticsコンソールには1000mが必要です。各ストリーミング・パイプラインには、設定に応じて追加のミリコアが必要です。Igniteクラスタがアクティブ化されている場合、少なくとも2つのクラスタ・インスタンスが必要です。ストリーム分析コンソールで、IgniteおよびGoldenGateビッグ・データ・クラスタの両方にミリコア制限を構成できます。一緒に追加すると、Stream Analyticsデプロイメントの作成時に選択する必要があるOCPUの合計数を決定できます。
不明な場合は、2または3 OCPUから開始し、デプロイメントの詳細ページでOCPU消費メトリックを確認して、それに応じて調整できます。