数据湖探索 DLI-从Kafka读取数据写入到DWS:步骤6:发送数据和查询结果

时间:2025-02-12 15:00:52

步骤6:发送数据和查询结果

  1. 使用Kafka客户端向步骤2:创建Kafka的Topic中的Topic发送数据,模拟实时数据流。

    Kafka生产和发送数据的方法请参考DMS - 连接实例生产消费信息

    发送样例数据如下:

    {"car_id":"3027", "car_owner":"lilei", "car_age":"7", "average_speed":"76", "total_miles":"15000"}{"car_id":"3028", "car_owner":"hanmeimei", "car_age":"6", "average_speed":"92", "total_miles":"17000"}{"car_id":"3029", "car_owner":"Ann", "car_age":"10", "average_speed":"81", "total_miles":"230000"}
  2. 连接已创建的DWS集群。

    具体操作请参考使用gsql命令行客户端连接DWS集群

  3. 执行以下命令连接DWS集群的默认数据库“testdwsdb”:
    gsql -d testdwsdb -h DWS集群连接地址 -U dbadmin -p 8000 -W password -r
  4. 查询DWS的表数据。
    select * from test.qualified_cars;
    查询结果参考如下:
    car_id  car_owner  car_age  average_speed  total_miles3027      lilei     7           76.0       15000.0
support.huaweicloud.com/devg-dli/dli_09_0010.html