[OCI]Micronautによるメッセージドリブン マイクロサービス＆モノリス - Part 3：Oracle Streaming Serviceへの切り替え (2021/02/01)

Micronautによるメッセージドリブン マイクロサービス＆モノリス - Part 3：Oracle Streaming Serviceへの切り替え (2021/02/01)

https://blogs.oracle.com/developers/message-driven-microservices-monoliths-with-micronaut-part-3%3a-switching-to-oracle-streaming-service
投稿者：Todd Sharp

これまでのシリーズ（パート 1、パート 2）では、最新の Web アプリケーションにおける
メッセージングに関連する「方法」と「理由」の両方を取り上げてきました。
E コマースの例を使ってメッセージングの必要性を説明し、ローカルの Kafka ブローカーを起動して、
Kafka ブローカーを介して通信する「Order」サービスと「Shipping」サービスの両方を作成することについて詳しく見てきました。
もしまだこの2つの記事を読んでいないのであれば、ここに進む前に読んでおくことを強くお勧めします。

読み終わった？よかった、これでスピードアップできましたね!
このシリーズの自然な次のステップは、このアプローチをクラウドベースのマイクロサービス(またはモノリシック)の
デプロイメントにどのように適用するかということだと思います。いつものように、アプローチはチームの好みに大きく依存します。
もしあなたのチームに強力なDevOpsがあり、手を汚すことを恐れていないのであれば、
適切なVMリソースを用意して、それをインストールして保守することで、クラウド上で独自のKafkaブローカを展開することを選択してもいいでしょう。
他のチームはこのアプローチを敬遠するかもしれませんが、メンテナンスのためのリソースが増えることを意味するので、
それは完全に理解できます（有料であることは言うまでもありません）。

独自のブローカーを実行しないようにすることを選択した人のために、利用可能な素晴らしいオプションがあります。
Oracle Streaming Service（OSS）です。OSSは、メッセージを消費し、生産するための完全に管理され、
スケーラブルで、耐久性があり、安全なサービスです。
これはマーケティングの話のように聞こえるかもしれませんが（たぶん私たちのマーケティングページからコピーしたものだから）、
本質的には、ここで話しているのは、セットアップやメンテナンスの手間をほとんどかけずに、
Kafkaメッセージングブローカーのすべての利点を提供するマネージドサービスです。
もちろん、この時点での最初の反対意見は、通常、アプリケーションコードをプロプライエタリなSDKにしっかりと結合することで、
「ベンダーロックイン」を恐れている人たちからのものです。
これは完全に有効な懸念ですが、サードパーティ製のAPIを使用したり、独自のRDBMSシステムを使用したりするときには、常にこのようなことをしていることを主張したいと思います。
OSS は Kafka API との互換性を提供しているので、設定を少し変更するだけで OSS を利用するようにOrderやShippingサービスを変更することができます。
OSS は Kafka API との互換性を提供しているからです。

注: このトピックについては以前の記事で詳しく書いています。
したがって、私はあなたのストリームやトピックを設定する方法については、あまり詳細に行くことはありません。
それらの詳細については、以前の記事をお読みください。

Oracle Streaming Serviceを使用するためにサービスを切り替える


この上のメモを見逃した場合は、ストリームとトピックの設定についての情報はこちらのブログ記事を参照してください。
これらのステップを経て、KAFKA_SASL_JAAS_CONFIGに環境変数を設定したら、次の変更を加えた新しい設定ファイルを
resources/application-oss.ymlに作成する準備ができました (必要に応じてサーバURLのリージョンを更新してください)。

kafka:
bootstrap:
servers: streaming.us-phoenix-1.oci.oraclecloud.com:9092
security:
protocol: SASL_SSL
sasl:
mechanism: PLAIN
jaas:
config: ${KAFKA_SASL_JAAS_CONFIG}


サービスを実行できるようになりました。

$ ./gradlew run -Dmicronaut.environments=oss

あなたのサービスは、ローカルのKafkaブローカーの代わりにOSSを利用するようになりました!
いや、本当に、それだけでいいのです。ローカルでいくつかの「Order」を行った後、
サービスが以前と同じように動作することを確認できます。
必要であれば、Oracle Cloud コンソールを介してメッセージを確認することもできます。

order-topic



shipping-topic



まとめ

この記事では、クラウドでのメッセージングのオプションについて説明し、
Oracle Streaming Serviceを使用することが有効で賢い選択である理由を見てみました。
次に、以前のEコマースのOrder・Shippingマイクロサービスでは、ローカルのKafkaブローカーをOSSに置き換えました。

この記事で使用したコードをGitHubでチェックしてみてください。


Image by 춘성 강 from Pixabay

コメント

コメントを投稿

このブログの人気の投稿

Oracle RACによるメンテナンスのためのドレインとアプリケーション・コンティニュイティの仕組み (2023/11/01)

イメージ
Oracle RACによるメンテナンスのためのドレインとアプリケーション・コンティニュイティの仕組み (2023/11/01) https://database-heartbeat.com/2023/11/01/draining-ac-rac/ はじめに Oracle RACは、Oracle Databaseのスケーラビリティと高可用性を提供します。1つのサーバー(RACノード)に障害が発生した場合、またはメンテナンスのためにオフラインになった場合でも、追加のノードを介してデータベースにアクセスできます。ただし、メンテナンスの開始時に、データの読取りまたは変更に関係なく、一部の作業を実行しているクライアント・セッションはどうなりますか。この作業は中断され、ドレインを実装してアプリケーション・コンティニュイティまたは透過的アプリケーション・コンティニュイティを有効にしないかぎり、エンドユーザーまたはアプリケーションによって再度実行する必要があります。 環境 2ノードのOracle RACを例に挙げて、高速アプリケーション通知(FAN)、ドレインおよびアプリケーション・コンティニュイティによってメンテナンス・イベントがエンドユーザーに透過的になる方法を理解しましょう。アプリケーションは、30個のセッションを保持するように構成された接続プールを使用しています。 通常の操作 通常の操作中は、両方のRACノードが起動し、アプリケーションを実行しています。ロード・バランシング戦略によっては、セッションの数が両方のノード間で異なるか、均等に分散される場合があります。次の図をよりよく視覚化するために、ノード2のノード1および20のセッションに10のセッションがあるとします。 セッションは、アイドル状態(接続されているが何もしていない)またはアクティブ状態(リクエストの途中)にできます。リクエストは、データの読取り(SELECT)または操作(INSERT、DELETE、UPDATE)が可能です。 ドレインによるサービスの停止 ある時点で、システムのメンテナンスが必要になります。2ノードRACがあるため、メンテナンスはローリング方式で、1つのノードを順番に(ほとんどの場合)実行できます。メンテナンスは、たとえば、オペレーティング・システム、Grid Infrastructureまたはデ
続きを読む

Oracle Cloud Infrastructure Secure Desktopsを発表: デスクトップ仮想化のためのOracleのクラウドネイティブ・サービス (2023/06/28)

イメージ
Oracle Cloud Infrastructure Secure Desktopsを発表: デスクトップ仮想化のためのOracleのクラウドネイティブ・サービス (2023/06/28) https://blogs.oracle.com/cloud-infrastructure/post/secure-desktops-cloud-native-virtualization 投稿者： Joost Pronk Van Hoogeveen Jan Hendrik Mangold | Principal Product Manager Oracleは、Oracle Cloud Infrastructure(OCI)Secure Desktopsという新しいクラウド・ネイティブ・サービスをリリースしています。このエキサイティングな開発により、顧客はOCIテナンシから簡単にすばやく仮想デスクトップ・インフラストラクチャ(VDI)をデプロイできます。 OCIの使用状況は大幅に拡大しています。組織は、OCI内でデータを安全に保つことの価値を実現しています。ゼロトラストなセキュリティ優先アーキテクチャを実装することで、OCI Compute、Storage、およびNetworkingサービスは、グローバル・アクセスのためのエンタープライズ・アプリケーションを導入するための信頼できるプラットフォームを提供します。 データ・セキュリティとVDIがどのように役立つか 業界のアナリストによると 、ラップトップは53秒ごとに盗まれています。その事実と現実を結び付けると、会社のデータは、公共の場所を経由したり、従業員の自宅に座ったりするラップトップやデスクトップへと移行します。ローカル・ディスクの暗号化、データ・アクセス権限の強制、VPNアクセスの保護によってデータを保護するためにテクノロジが使用されていますが、いずれも許容可能なセキュリティ・レベルが適用されるため、リスクは依然として高くなる可能性があります。盗難または準拠していないいくつかのマシンでは、企業データ、さらには顧客データのデータ侵害が発生する可能性があります。 VDIテクノロジは長年にわたって存在してきましたが、従業員はローカル・マシンを使用して、会社のデータ・センター内の仮想マシンで実行されているデスクトップ・アプリケー
続きを読む

新しいOracle Container Engine for Kubernetesの機能強化により、大規模なKubernetesがさらに簡単になりました (2023/03/20)

イメージ
新しいOracle Container Engine for Kubernetesの機能強化により、大規模なKubernetesがさらに簡単になりました (2023/03/20) https://blogs.oracle.com/cloud-infrastructure/post/oracle-container-engine-kubernetes-enhancements 投稿者： Mickey Boxell | Product Management Linux以降、 Kubernetes はオープンソースソフトウェアの歴史上最も急速に成長しているプロジェクトです。10年も経たないうちに、 Kubernetesは主流 になり、特に過去2年間で導入がかつてないほど大きくなりました。 Oracle Cloud Infrastructure(OCI) は、この勢いも見ています。あらゆる業界の何千ものエンタープライズ顧客が、クラウドネイティブアプリケーション開発のメリットを経験しており、その導入を迅速化し、Kubernetesの使用を拡大しています。 Oracle Container Engine for Kubernetes (OKE)で実行されている抽出、変換、ロード(ETL)ジョブ、パイプライン、ハイパフォーマンスコンピューティング(HPC)ワークロード、さらにはデータベースなどにKubernetesを使用するために、顧客はKubernetesで標準化されており、コンテナ化されたアプリケーションを実行するのみでなく拡張されています。  「私たちは、Kubernetes インフラストラクチャと OKE、GPU、HPC、およびストリーミング、OpenSearch などの最新の開発者サービスを組み合わせて使用​​して、OCI で数十億の音声 AI クエリを実行しています。私たちは、次世代のトレーニングと配信に最適なクラウドとして OCI を選択しました。 AI アプリケーション – Mercedes Benz、Toast、VIZIO、Hyundai などのグローバル ブランドに最速かつ最も正確な音声エクスペリエンスを提供するのに役立ちます.OCI を使用することで、以前のクラウドと比較してパフォーマンスが 50 ～ 60% 向上しました。 2 倍のコスト削減 – 使用量
続きを読む