检查以下代码。

scala> "cat /tmp/sample.yaml".!
 rawSource:
   DEALER_MASTER :
    staginDir :
      - "ADLS BLOB LOCATION"
    rawLayerTbl:
      - "TABLE_NAME"
    fileDelimiter :
      - "|"
   CUSTOMER_VEHICLE :
    staginDir :
      - "ADLS BLOB LOCATION"
    rawLayerTbl:
      - "TABLE_NAME"
    fileDelimiter :
      - "|"
   EMPLOYEE_MASTER :
    staginDir :
      - "ADLS BLOB LOCATION"
    rawLayerTbl:
      - "TABLE_NAME"
    fileDelimiter :
      - "|"
   CUSTOMERCREDIT_MASTER :
    staginDir :
      - "ADLS BLOB LOCATION"
    rawLayerTbl:
      - "TABLE_NAME"
    fileDelimiter :
      - "|"
   CONTINUOUS_CAN_MASTER :
    staginDir :
      - "ADLS BLOB LOCATION"
    rawLayerTbl:
      - "TABLE_NAME"
    fileDelimiter :
      - "|"
   LOGIN_TABLE:
    staginDir:
      - "ADLS BLOB LOCATION"
    rawLayerTbl:
      - "TABLE_NAME"
    fileDelimiter:
      - "|"

scala> def loadYAML(path: String): String = {
     |     import com.fasterxml.jackson.databind.ObjectMapper
     |     import com.fasterxml.jackson.dataformat.yaml.YAMLFactory
     |
     |     val yaml = scala.io.Source.fromFile(path).getLines().mkString(" \n ")
     |     val yamlReader = new ObjectMapper(new YAMLFactory)
     |     val obj = yamlReader.readValue(yaml, classOf[Any])
     |     val jsonWriter = new ObjectMapper
     |     jsonWriter.writeValueAsString(obj)
     | }
loadYAML: (path: String)String

scala> def getConfig(key: String)(yaml: String):(String,String,String) = {
     |   import org.json4s._
     |   import org.json4s.jackson.JsonMethods._
     |   implicit val formats = DefaultFormats
     |
     |   val json = parse(yaml)
     |   val staginDir = ( json \\ key \ "staginDir").extract[List[String]].head
     |   val rawLayerTbl = ( json \\ key \ "rawLayerTbl").extract[List[String]].head
     |   val fileDelimiter = ( json \\ key \ "fileDelimiter").extract[List[String]].head
     |   (staginDir, rawLayerTbl, fileDelimiter)
     | }
getConfig: (key: String)(yaml: String)(String, String, String)

scala> val yaml = loadYAML("/tmp/sample.yaml")
yaml: String = {"rawSource":{"DEALER_MASTER":{"staginDir":["ADLS BLOB LOCATION"],"rawLayerTbl":["TABLE_NAME"],"fileDelimiter":["|"]},"CUSTOMER_VEHICLE":{"staginDir":["ADLS BLOB LOCATION"],"rawLayerTbl":["TABLE_NAME"],"fileDelimiter":["|"]},"EMPLOYEE_MASTER":{"staginDir":["ADLS BLOB LOCATION"],"rawLayerTbl":["TABLE_NAME"],"fileDelimiter":["|"]},"CUSTOMERCREDIT_MASTER":{"staginDir":["ADLS BLOB LOCATION"],"rawLayerTbl":["TABLE_NAME"],"fileDelimiter":["|"]},"CONTINUOUS_CAN_MASTER":{"staginDir":["ADLS BLOB LOCATION"],"rawLayerTbl":["TABLE_NAME"],"fileDelimiter":["|"]},"LOGIN_TABLE":{"staginDir":["ADLS BLOB LOCATION"],"rawLayerTbl":["TABLE_NAME"],"fileDelimiter":["|"]}}}

输出

scala> val (staginDir, rawLayerTbl, fileDelimiter) = getConfig("CUSTOMER_VEHICLE")(yaml)
staginDir: String = ADLS BLOB LOCATION
rawLayerTbl: String = TABLE_NAME
fileDelimiter: String = |