サンプルメッセージの生成 - 7.1

Talend Data Fabric入門ガイド

author
Talend Documentation Team
EnrichVersion
7.1
EnrichProdName
Talend Data Fabric
task
インストールとアップグレード
ジョブデザインと開発
データクオリティとプレパレーション > データクレンジング
データクオリティとプレパレーション > データプロファイリング
EnrichPlatform
Talend Administration Center
Talend DQ Portal
Talend Installer
Talend Runtime
Talend Studio
実際の運用では、Kafkaへのメッセージを生成するシステムは完全に分離されます。ですが、このシナリオでは、Kafka自体がサンプルメッセージの生成に使用されます。これらのメッセージを生成するには、以下の操作を行う必要があります。

手順

  1. メッセージの分類に使用するKafkaトピックを作成します。次のコマンドは、デモンストレーションの目的でのみ使用されます。Kafkaトピックの作成について詳しい情報が必要な場合は、Kafkaに関するApacheのドキュメンテーションを参照して下さい。
    /usr/lib/kafka/bin/kafka-topics.sh --zookeeper localhost:2181 --create --topic activities --partitions 1 --replication-factor 1

    このコマンドは、localhostマシンでZookeeperサービスによって管理されるKafkaブローカーを使用して、activitiesという名前のトピックを作成します。

  2. 分析するメッセージを、作成したばかりのactivitiesトピックにパブリッシュします。このシナリオでは、Kafkaはたとえば次のコマンドを使用して、このパブリッシュを行うために使われます。
    echo 'Ryan|M|Pool
    Remy|M|Drink
    Remy|M|Hiking
    Irene|F|Drink
    Pierre|M|Movie
    Irene|F|Pool
    Thomas|M|Drink
    Ryan|M|Cooking
    Wang|F|Cooking
    Chen|M|Drink | /usr/lib/kafka/bin/kafka-console-producer.sh --broker-list  localhost:9092 --topic  activities

    このコマンドは10のシンプルメッセージをパブリッシュします。

    Ryan|M|Pool
    Remy|M|Drink
    Remy|M|Hiking
    Irene|F|Drink
    Pierre|M|Movie
    Irene|F|Pool
    Thomas|M|Drink
    Ryan|M|Cooking
    Wang|F|Cooking
    Chen|M|Drink

タスクの結果

先に説明したように、代わりに実際のメッセージプロデューサーシステムを使用してパブリッシュを行うことができます。