4

我正在寻找一些适合 akka 的 scala 实用程序，它们可以将HOCON映射到 Scala 类/对象。（类似于@ConfigurationSpring 将.ymlor.properties文件映射到配置 bean/Java 类。）

我对PureConfig的尝试：

spark.conf资源中的配置文件

spark{
    master {
        host = 1.2.3.4
        port = 7077
    }
}

映射到以下 scala 类：

trait Configuration {
    val nameSpace: String
}

case class SparkConfig(master: SparkMasterConfig) extends Configuration {
    override val nameSpace: String = "spark"
}

case class SparkMasterConfig(host: String,
                                    port: Int)

PureConfig 在没有泛型的情况下工作正常：

import pureconfig.generic.auto._
import com.typesafe.config.ConfigFactory

val conf = ConfigFactory.parseResources("spark.conf")
val sparkConfig = pureconfig.loadConfig[SparkConfig]("spark")

val config = sparkConfig match {
    case Left(f) => fail(f.toString)
    case Right(c) => c
}

但是，以下通用 util 甚至没有编译not enough arguments for method 错误

object PureConfigLoader{
    def load[T <: Configuration](clazz: Class[T]): T = {
        val nameSpace = clazz.getField("nameSpace").get().asInstanceOf[String]

        import pureconfig.generic.auto._
        val configResult = pureconfig.loadConfig[T](nameSpace)  // this doesn't compile

        configResult match {
            case Right(x) => x.asInstanceOf[T]
            case Left(x) => throw new IllegalArgumentException(s"Fail to parse ${clazz.getSimpleName} from namespace $nameSpace")
        }
    }
}

val config = PureConfigLoader.load(classOf[SparkConfig])

我的问题是：

  1. 我可以用这个通用的 PureConfig 工具做什么？
  2. import pureconfig.generic.auto._IntelliJ 始终将其标记为未使用的导入，并且在格式化我的代码时将其删除，如何解决此问题？
  3. 是否有任何其他配置工具/库以类似的方式正常工作？我也尝试过circe-config但仍然遇到类似的问题。Simple Scala Config使用 Scala 的 Dynamic 不利于重构，例如重命名配置属性字段。

谢谢

4

1 回答 1

2

我使用Typesafe config的一个小包装器：

https://github.com/kxbmap/configs

我试过你的例子 - 这编译：

  object PureConfigLoader{
    def load[T <: MyConfig[T]](clazz: Class[T])(implicit A: Configs[T]): T = {
      val nameSpace = clazz.getField("nameSpace").get().asInstanceOf[String]

      val config = ConfigFactory.load("spark.conf")
        Configs[T].get(config, nameSpace) 
          .valueOrThrow(e=>
             new IllegalArgumentException(s"Fail to parse ${clazz.getSimpleName} from namespace $nameSpace: ${e.messages}" 
          )
      )
    }
  }

  val sparkConfig = PureConfigLoader.load(classOf[SparkConfig])

  abstract class MyConfig[T] (implicit A: Configs[T])

  case class SparkConfig() extends MyConfig[SparkConfig]

更新

我刚刚在我们的代码中看到您可能根本不需要这个 Util 类！我们用：

val config = ConfigFactory.load("spark.conf")
val sparkConfig = Configs[SparkConfig].get(config, nameSpace)
于 2019-04-24T07:08:19.530 回答