Elasticsearch を活用したインテリジェントな B2B サプライヤー検索エンジン
ベンダープラットフォームは、数千の国際的なサプライヤーにわたる複雑な多面的なクエリを1秒未満の応答時間で処理できる高性能な検索エンジンを必要としていました。
プロジェクトを相談する
課題
従来のデータベースクエリでは、検索要件を満たすことができませんでした:
- SQL では、ベンダーごとに80以上のフィールドにわたる全文検索が遅すぎました
- 優先度に基づくランキングには、データの完全性と検証を考慮する必要がありました
- ソーシャルメディアの存在は、第一級の属性として検索可能である必要がありました
- ファジーマッチングと入力ミスへの許容は、国際的なサプライヤー名にとって不可欠でした
- カテゴリと場所の階層には、ファセット検索機能が必要でした
私たちのソリューション
当社は、ベンダー発見のために、優先度ベースのインデックス作成、多フィールド検索、インテリジェントなランキングを備えたカスタム Elasticsearch 統合を実装しました。
アーキテクチャ
- 検索エンジン: ベンダー、カテゴリ、ソーシャルメディア用のカスタムマッピングを備えた Elasticsearch
- データ層: 真の情報源として TypeORM/PostgreSQL、Elasticsearch に同期
- API層: Elasticsearch クライアントを備えた Node.js/Express
- フロントエンド: リアルタイムのタイプ入力検索機能を備えた React
- 分析: 検索行動追跡用の PostHog
検索機能
- 多フィールド検索 - ベンダー名、説明、ブランド、カテゴリを同時にクエリ
- ソーシャルメディアフィルタリング - 特定のプラットフォームでの存在に基づいてベンダーを検索
- カテゴリファセット - 製品カテゴリ階層をドリルダウン
- 場所フィルタリング - 国、地域、または都市で検索
- 優先度ランキング - 検証済みでデータが完全なベンダーが上位にランク付けされます
- ファジーマッチング - 入力ミスや国際的な名前のバリエーションを処理
主要機能
- カスタムインデックスマッピング - ベンダー、カテゴリ、ソーシャルメディアデータ向けに最適化されたスキーマ
- リアルタイム同期 - データベースの変更が数秒以内に検索に反映されます
- 検索分析 - 人気のあるクエリ、結果がゼロの検索、クリック率を追跡
- 一括インデックス作成 - 大規模なベンダーインポートのための効率的なバッチインデックス作成
- 加重スコアリング - フィールドの重要度に基づいた設定可能な関連性スコアリング
成果
技術スタック
caseStudyDetail.more ケーススタディ
その他の技術実装事例をご覧ください
AIを活用したベンダー発見&ソーシングプラットフォーム
Eコマース企業や輸入業者は、AlibabaのようなB2Bマーケットプレイスを手作業で検索するプロセスに代わる、国際的なサプライヤーを発見、評価、管理するためのインテリジェントなプラットフォームを必要としていました。
AIを活用したOCRによる請求書処理とQuickBooks連携
毎月数百件の仕入先請求書を処理する中規模企業が、AI/OCRを使用して請求書データを自動抽出し、それを記帳と支払追跡のためにQuickBooksに直接同期させることで、手動データ入力を排除する必要がありました。
よくある質問
MicrocosmWorksは、部分一致のためのedge n-gram tokenization、業界用語のためのシノニム辞書、および正確な部品番号検索のための専用キーワードフィールドを組み合わせたカスタムアナライザーでElasticsearchを構成しました。このアプローチにより、買い手がサプライヤーのカタログに記載されているものとは異なる専門用語を使用しても、関連するサプライヤーが返されます。
MicrocosmWorksは、業界業種に基づいてサプライヤーのドキュメントを複数のノードに分散させるシャーディング戦略を用いてElasticsearchクラスターを設計し、再インデックスなしでの水平スケーリングを可能にしました。このアーキテクチャは、地理的な分散のためのクロス・クラスター検索をサポートしており、数百万のサプライヤーレコードであっても200ミリ秒以下のクエリ応答時間を維持します。
はい、MicrocosmWorksは、近接性、MOQ適合性、リードタイム、認証要件、過去の取引履歴といった購入者定義の重みに基づいてサプライヤーのランキングを動的に引き上げるfunction score queriesを実装しました。購入者は重み付けプロファイルを保存し、一貫した調達設定のために検索全体に適用できます。
MicrocosmWorks は、PostgreSQL ソースデータベースに接続された Debezium を使用して変更データキャプチャパイプラインを構築し、Kafka を介してサプライヤーレコードの変更をほぼリアルタイムで Elasticsearch にストリーミングしています。これにより、バッチ再インデックスサイクルを待つことなく、検索結果が数秒以内にデータベースの更新を反映することが保証されます。
MicrocosmWorksは、Elasticsearchを活用した検索ソリューションを1時間あたり$20〜$45の料金で提供しています。カスタムアナライザー、関連性チューニング、ファセット検索、およびCDCパイプラインを含む完全なB2Bサプライヤー検索エンジンには、通常350〜550時間の開発時間が必要です。Elasticsearchインフラストラクチャ自体は、AWS上で月額約$500から利用可能な3ノードクラスターで費用対効果高く運用できます。