spark气象项目，使用dsl方法写出各个城市的平均气温，写在service包下

好的，您可以参考以下代码：

package service

import org.apache.spark.sql.SparkSession
import org.apache.spark.sql.functions._
import org.apache.spark.sql.types._

object WeatherService {
  
  def getAvgTemperatureByCity(spark: SparkSession, path: String): Unit = {
    
    // Define the schema of the weather data
    val schema = StructType(Seq(
      StructField("city", StringType, false),
      StructField("date", DateType, false),
      StructField("temperature", DoubleType, false)
    ))
    
    // Read the weather data from the given path
    val weatherData = spark.read.schema(schema).csv(path)
    
    // Calculate the average temperature by city
    val avgTemperatureByCity = weatherData
      .groupBy("city")
      .agg(avg("temperature").as("avg_temperature"))
      .orderBy("city")
    
    // Print the result
    avgTemperatureByCity.show()
  }
  
}

这段代码实现了一个名为 `WeatherService` 的对象，其中包含了一个名为 `getAvgTemperatureByCity` 的方法。该方法接收两个参数：`spark` 表示 SparkSession 对象，`path` 表示气象数据所在的路径。

方法中首先定义了气象数据的 schema，然后使用该 schema 读取了气象数据，并通过 `groupBy` 和 `agg` 方法计算每个城市的平均气温。最后将结果按城市名称排序，并打印出来。

您可以将以上代码保存为 `WeatherService.scala` 文件，并在您的项目中引入该文件，然后调用 `WeatherService.getAvgTemperatureByCity(spark, path)` 方法即可。