java - 尝试使用 ConfigFactory.parseString 时未找到密钥“conf”的配置设置
问题描述
我正在尝试读取存储在我的 s3 存储桶中的 application.conf。我使用 Bufferedsource 从 s3 读取,但是当我尝试使用ConfigFactory.parseString(source.mkString).getConfig("conf")
它时没有找到那里的“conf”。下面是我的源代码:
import com.amazonaws.auth.DefaultAWSCredentialsProviderChain
import com.amazonaws.services.s3.model.S3Object
import com.amazonaws.services.s3.{AmazonS3Client, AmazonS3ClientBuilder, AmazonS3URI}
import scala.collection.JavaConversions._
import scala.io.{BufferedSource, Source}
object Test {
def main(args: Array[String]): Unit = {
import com.amazonaws.auth.BasicAWSCredentials
val credentials = new BasicAWSCredentials("key", "secertkey")
// val credentialsProvider = new DefaultAWSCredentialsProviderChain()
val s3Client = new AmazonS3Client(credentials)
val uri: AmazonS3URI = new AmazonS3URI("s3://test-buck/conf/application.conf")
val s3Object: S3Object = s3Client.getObject(uri.getBucket, uri.getKey)
val source: BufferedSource = Source.fromInputStream(s3Object.getObjectContent)
try {
println(source.mkString)
import com.typesafe.config.{Config, ConfigFactory}
val rawConfig: Config = ConfigFactory.parseString(source.mkString)
val rootConfig = rawConfig.getConfig("conf")
println(rootConfig)
// println(rotConfig)
} finally {
source.close()
}
}
}
我的应用程序配置如下所示
conf {
source_data_list = ["OL", "SB","1CP"]
//some other value
OL {
filename = "receipts_delta_GBR_14_10_2017.csv"
sftp_conf {
hostname = "endpoint"
port = "22"
username = "ubuntu"
pem = "pemfile"
filetype = "csv"
delimiter = "|"
directory = "/home/ubuntu/data"
}
}
}
不知道我在这里做错了什么。如果我放入资源并尝试通过ConfigFactory.load("application.conf").getConfig("conf")
它加载,则相同的应用程序配置按预期工作。这方面的任何线索都会有所帮助。
我得到的例外
线程“main”中的异常 线程“main”中的异常 com.typesafe.config.ConfigException$Missing:在 com.typesafe.config.impl.SimpleConfig.findKey(SimpleConfig.java:124) 中找不到键 'conf' 的配置设置在 com.typesafe.config.impl.SimpleConfig.find(SimpleConfig.java:145) 在 com.typesafe.config.impl.SimpleConfig.find(SimpleConfig.java:159) 在 com.typesafe.config.impl.SimpleConfig.find (SimpleConfig.java:164) 在 com.typesafe.config.impl.SimpleConfig.getObject(SimpleConfig.java:218) 在 com.typesafe.config.impl.SimpleConfig.getConfig(SimpleConfig.java:224) 在 com.typesafe。 com.dsm.utils.Test$.main(Test.scala:26) 上 com.dsm.utils.Test.main(Test.scala) 上的 config.impl.SimpleConfig.getConfig(SimpleConfig.java:33)
解决方案
实际上你成功读取了配置。
你遇到的问题是因为BufferedSource
. 缓冲源可以读取一次。你读了它,我猜是为了调试,然后源代码就结束了。第二次阅读时,为了填充,rawConfig
您会得到一个空字符串。我通过将配置字符串提取到变量中,然后使用它来解决它。
val config = source.mkString
println(s"config is: $config")
val rawConfig: Config = ConfigFactory.parseString(config)
val rootConfig = rawConfig.getConfig("conf")
println(s"rootConfig is: $rootConfig")
输出是:
rootConfig is: Config(SimpleConfigObject({"OL":{"filename":"receipts_delta_GBR_14_10_2017.csv","sftp_conf":{"delimiter":"|","directory":"/home/ubuntu/data","filetype":"csv","hostname":"endpoint","pem":"pemfile","port":"22","username":"ubuntu"}},"source_data_list":["OL","SB","1CP"]}))
推荐阅读
- android - 如何获取外部存储android的路径?
- android - 如果使用 alignParentTop,Android 阴影不起作用
- javascript - OfficeJS addHandlerAsync 回调不执行角度组件方法
- python - 如何打印从 1 到 1000 的数字,然后在同一个循环中只打印偶数
- reactjs - 创建依赖状态的组件变量?最佳做法?
- java - concurrentHashMap 有一个 volatile 表,为什么 get() 时需要 unsafe.getObjectVolatile()
- firebase - 检查firebase文档中的特定字段并在找到字段时返回文档ID?
- spring-boot - 如何从不属于 pojo 的 html 传递字段?
- ios - 表单内 Swift 中的选择器控件有什么问题?
- node.js - 如何从云存储node.js客户端中的url上传文件