データの取り込みと変換
データを取り込み、クエリに値するものにします。
生データからモデル化されたテーブルへ
まずは取り込みです。Apache Kafkaからのストリーミングは、ブローカーをソースとして接続し、トピックからテーブルを最新の状態に保ちます。IoTフリートモニタリングパイプラインは、より長く作業された例で、デバイスメッセージをダッシュボードまで2部構成で処理し、ここではフルリファレンスアーキテクチャに最も近いものです。
次に変換です。Python SDKチュートリアルでは、カスタムアクションがテーブルを読み込み、データフレームで変更し、それを書き戻す方法を示しています。SQL変換は、Trinoエンジン上でSQLを使用して同じ作業を行います。外部データセットを使用したデータモデルは、プラットフォームがコピーしないデータ上にテーブルを構築します。セグメンテーションはパフォーマンスの章です。日付、属性、ファイルセット、またはアカウントごとに1つのジョブを並列タスクに分割し、各モードをカバーする7つの短いガイドです。
ソースに合ったものを選んでください。または、フルパイプラインを構築するために順番に読むこともできます。
Apache Kafkaからデータをストリーミング→
トピックからテーブルを最新の状態に保つ
IoTフリート監視パイプラインの構築→
デバイスメッセージをダッシュボードに伝達、2部構成
Python SDKを使用したデータ変換→
テーブルを読み取り、データフレームで変更し、書き戻す
SQL変換→
Trinoエンジン上でSQLによる同じ作業
外部データセットを使用したデータモデル→
プラットフォームがコピーしないデータ上でモデリング
ジョブにセグメンテーションを適用→
1つのジョブを並列タスクに分割、7つのモードをカバー
さらに深く掘り下げる
当社のソリューションを実装するためのトレーニングや技術サポートが必要な場合は、営業担当者にお問い合わせください、またはこのリンクをクリックして見積もりを依頼し、当社のプロフェッショナルサービスの専門家にプロジェクトのカスタム分析を依頼してください。
Data Platformを構築するチームと直接質問したり、フィードバックを送信したり、Discordチャネルで交流したりするには、専用のDiscordチャネルにアクセスしてください。
OVHcloudサービスについてサポートが必要な場合は、ヘルプセンターでリクエストを作成してください。
ユーザーコミュニティに参加してください。

