我打算基于模板和sbt设置生成资源.应该有不同的SBT设置Compile和Test.模板在project/resources/hdfs/*.xml.从sbt-dev gitter聊天中,我有建议使用Setting和inConfig,但我无法让它工作.
代码到目前为止:
val hdfsNamenode = settingKey[String]("Namenode for the HDFS access")
def genHdfsConfigs: Setting[_] =
hdfsNamenode := {
resourceGenerators += Def.task {
val files = ((baseDirectory.value / "project" / "resources" / "hdfs" ) * "*.xml").get
files.foreach({ hdfsTemplate =>
val config = IO.read(hdfsTemplate).replace("{{namenode}}", hdfsNamenode.value)
IO.write(resourceManaged.value / hdfsTemplate.getName, config)
})
files.toSeq
}.taskValue
}
hdfsNamenode in Test := "localhost"
hdfsNamenode in Compile := "172.31.32.228"
def allHdfsNamenodeConfigs: Seq[Setting[_]] =
inConfig(Compile)(Seq(hdfsNamenode)) ++ inConfig(Test)(Seq(hdfsNamenode))
Run Code Online (Sandbox Code Playgroud)
错误:
[error] found : sbt.Def.Setting[Seq[sbt.Task[Seq[java.io.File]]]]
[error] required: String
[error] resourceGenerators += Def.task {
[error] ^
[error] found : sbt.SettingKey[String]
[error] required: sbt.Def.Setting[_]
[error] inConfig(Compile)(Seq(hdfsNamenode)) ++ inConfig(Test)(Seq(hdfsNamenode))
[error]
Run Code Online (Sandbox Code Playgroud)
下一次迭代,我不知道怎么弄的hdfsNameNode范围Compile/ Test,而不是未范围.
lazy val hdfsNameNode = settingKey[String]("Namenode for the HDFS access")
val genHdfsConfig = Def.task {
val files = ((baseDirectory.value / "project" / "templates" / "resources" / "hdfs" ) * "*.xml").get
files.map({ hdfsTemplate =>
val config = IO.read(hdfsTemplate).replace("{{namenode}}", hdfsNameNode.value)
val outputPath = resourceManaged.value / hdfsTemplate.getName
IO.write(outputPath, config)
outputPath
})
}
Seq(
hdfsNameNode := "undefined", // Only this one is accepted
hdfsNameNode in Test := "localhost",
hdfsNameNode in Compile := "172.31.32.228",
resourceGenerators in Compile += genHdfsConfig.taskValue,
resourceGenerators in Test += genHdfsConfig.taskValue
)
Run Code Online (Sandbox Code Playgroud)
当前(丑陋)的解决方案:
val hdfsTestNameNode = "localhost"
val hdfsMainNameNode = "172.31.32.228"
val hdfsNameNode = settingKey[String]("Namenode for the HDFS access")
val genTestHdfsConfig = Def.task {
val files = ((baseDirectory.value / "project" / "templates" / "resources" / "hdfs" ) * "*.xml").get
files.map({ hdfsTemplate =>
val config = IO.read(hdfsTemplate).replace("{{namenode}}", (hdfsNameNode in Test).value)
val outputPath = resourceManaged.value / hdfsTemplate.getName
IO.write(outputPath, config)
outputPath
})
}
val genCompileHdfsConfig = Def.task {
val files = ((baseDirectory.value / "project" / "templates" / "resources" / "hdfs" ) * "*.xml").get
files.map({ hdfsTemplate =>
val config = IO.read(hdfsTemplate).replace("{{namenode}}", (hdfsNameNode in Compile).value)
val outputPath = resourceManaged.value / hdfsTemplate.getName
IO.write(outputPath, config)
outputPath
})
}
Seq(
hdfsNameNode in Test := hdfsTestNameNode,
hdfsNameNode in Compile := hdfsMainNameNode,
resourceGenerators in Compile += genCompileHdfsConfig.taskValue,
resourceGenerators in Test += genTestHdfsConfig.taskValue
)
Run Code Online (Sandbox Code Playgroud)
在定义资源生成器时,只需将Configuration作为参数传递.
val hdfsTestNameNode = "localhost"
val hdfsMainNameNode = "172.31.32.228"
val hdfsNameNode = settingKey[String]("Namenode for the HDFS access")
def genHdfsConfig(cfg: Configuration) = Def.task {
val files = ((baseDirectory.value / "project" / "templates" / "resources" / "hdfs" ) * "*.xml").get
files.map({ hdfsTemplate =>
val config = IO.read(hdfsTemplate).replace("{{namenode}}", (hdfsNameNode in cfg).value)
val outputPath = (resourceManaged in cfg).value / hdfsTemplate.getName
IO.write(outputPath, config)
outputPath
})
}
Seq(
hdfsNameNode in Test := hdfsTestNameNode,
hdfsNameNode in Compile := hdfsMainNameNode,
resourceGenerators in Compile += genHdfsConfig(Compile).taskValue,
resourceGenerators in Test += genHdfsConfig(Test).taskValue
)
Run Code Online (Sandbox Code Playgroud)
不想指定范围两次?只需重构一下.
val hdfsTestNameNode = "localhost"
val hdfsMainNameNode = "172.31.32.228"
val hdfsNameNode = settingKey[String]("Namenode for the HDFS access")
def addHdfsConfigGenerator(cfg: Configuration) = {
inConfig(cfg) {
val hdfsConfigGenerator = Def.task {
val files = ((baseDirectory.value / "project" / "templates" / "resources" / "hdfs" ) * "*.xml").get
files.map({ hdfsTemplate =>
val config = IO.read(hdfsTemplate).replace("{{namenode}}", (hdfsNameNode in cfg).value)
val outputPath = (resourceManaged in cfg).value / hdfsTemplate.getName
IO.write(outputPath, config)
outputPath
})
}
resourceGenerators += hdfsConfigGenerator.taskValue
} last
}
Seq(
hdfsNameNode in Test := hdfsTestNameNode,
hdfsNameNode in Compile := hdfsMainNameNode,
addHdfsConfigGenerator(Compile),
addHdfsConfigGenerator(Test)
)
Run Code Online (Sandbox Code Playgroud)
| 归档时间: |
|
| 查看次数: |
181 次 |
| 最近记录: |