Como ler arquivos da pasta de recursos no Scala?

112

Eu tenho uma estrutura de pastas como a abaixo:

- main
-- java
-- resources 
-- scalaresources
--- commandFiles 

e nessas pastas tenho meus arquivos que devo ler. Aqui está o código:

def readData(runtype: String, snmphost: String, comstring: String, specificType:  String): Unit = {
  val realOrInvFile = "/commandFiles/snmpcmds." +runtype.trim // these files are under commandFiles folder, which I have to read. 
    try {
      if (specificType.equalsIgnoreCase("Cisco")) {
        val specificDeviceFile: String = "/commandFiles/snmpcmds."+runtype.trim+ ".cisco"
        val realOrInvCmdsList = scala.io.Source.fromFile(realOrInvFile).getLines().toList.filterNot(line => line.startsWith("#")).map{
          //some code 
        }
        val specificCmdsList = scala.io.Source.fromFile(specificDeviceFile).getLines().toList.filterNot(line => line.startsWith("#")).map{
          //some code
        }
      }
    } catch {
      case e: Exception => e.printStackTrace
    }
  }
}
Pradip Karad
fonte
porque a resposta fornecida por Andreas Neumann não foi aceita se você tiver alguma pergunta complementar, comente. -1.
Vishrant

Respostas:

201

Os recursos em Scala funcionam exatamente como em Java. É melhor seguir as melhores práticas de Java e colocar todos os recursos em src/main/resourcesesrc/test/resources .

Exemplo de estrutura de pasta:

testing_styles/
├── build.sbt
├── src
│   └── main
│       ├── resources
│       │   └── readme.txt

Scala 2.12.x && 2.13.x lendo um recurso

Para ler recursos, o objeto Source fornece o método fromResource .

import scala.io.Source
val readmeText : Iterator[String] = Source.fromResource("readme.txt").getLines

ler recursos anteriores ao 2.12 (ainda meu favorito devido à compatibilidade do jar)

Para ler recursos, você pode usar getClass.getResource e getClass.getResourceAsStream .

val stream: InputStream = getClass.getResourceAsStream("/readme.txt")
val lines: Iterator[String] = scala.io.Source.fromInputStream( stream ).getLines

feedback de erro mais agradável (2.12.x && 2.13.x)

Para evitar NPEs Java que não podem ser compilados, considere:

import scala.util.Try
import scala.io.Source
import java.io.FileNotFoundException

object Example {

  def readResourceWithNiceError(resourcePath: String): Try[Iterator[String]] = 
    Try(Source.fromResource(resourcePath).getLines)
      .recover(throw new FileNotFoundException(resourcePath))
 }

bom saber

Lembre-se de que getResourceAsStream também funciona bem quando os recursos fazem parte de um jar , getResource , que retorna uma URL que costuma ser usada para criar um arquivo pode causar problemas nesse local.

em produção

No código de produção, sugiro certificar-se de que o código-fonte seja fechado novamente.

Andreas Neumann
fonte
Que tipo de problema poderia ocorrer se usar getResource e transformá-lo em um arquivo? Você pode fornecer um link?
akauppi
2
Em algumas circunstâncias como um Ponteiro nulo: stackoverflow.com/questions/941754/…
Andreas Neumann
Este código provavelmente está deixando o manipulador aberto para getResourceAsStream.
Sisso
3
não se esqueça closeda Fonte
Guillaume Massé
1
Obrigado! Os tipos de Byt não correspondem na seção de feedback de erro Nicer (2.12.x) . E quanto a vazamentos de memória? O recurso não deveria ser fechado?
Albert Bikeev
30

Para Scala> = 2,12, use Source.fromResource:

scala.io.Source.fromResource("located_in_resouces.any")
Mohsen Kashi
fonte
13
Importante: com Source.fromResourcevocê, não coloque a barra inicial que você tem com getResourceAsStream.
vossad01
6
E observe que este é 2.12+
rbellamy
e as versões 2.10?
Jaydev
12

Solução Onliner para Scala> = 2,12

val source_html = Source.fromResource("file.html").mkString
Freedev
fonte
4
import scala.io.Source

object Demo {

  def main(args: Array[String]): Unit = {

    val fileStream = getClass.getResourceAsStream("/json-sample.js")
    val lines = Source.fromInputStream(fileStream).getLines
    lines.foreach(line => println(line))

  }

}

insira a descrição da imagem aqui

EDIT: Crédito ao autor original. Consulte o blog completo aqui

Sri
fonte
Ao copiar de um site, poste um link para o autor original. Dê crédito a quem é devido. Consulte: fruzenshtein.com/scala-working-with-resources-folders-files
ForeverLearner
2

Para Scala 2.11 , se getLines não fizer exatamente o que você deseja, você também pode copiar o arquivo do jar para o sistema de arquivos local.

Este é um snippit que lê uma chave binária de API de formato google .p12 de / resources, grava em / tmp e usa a string de caminho de arquivo como uma entrada para uma gravação de spark-google-spreadsheets .

No mundo do sbt-native-packager e sbt-assembly , copiar para o local também é útil com os testes de arquivo binário escalatest. Basta retirá-los dos recursos para o local, executar os testes e excluí-los.

import java.io.{File, FileOutputStream}
import java.nio.file.{Files, Paths}

def resourceToLocal(resourcePath: String) = {
  val outPath = "/tmp/" + resourcePath
  if (!Files.exists(Paths.get(outPath))) {
    val resourceFileStream = getClass.getResourceAsStream(s"/${resourcePath}")
    val fos = new FileOutputStream(outPath)
    fos.write(
      Stream.continually(resourceFileStream.read).takeWhile(-1 !=).map(_.toByte).toArray
    )
    fos.close()
  }
  outPath
}

val filePathFromResourcesDirectory = "google-docs-key.p12"
val serviceAccountId = "[something]@drive-integration-[something].iam.gserviceaccount.com"
val googleSheetId = "1nC8Y3a8cvtXhhrpZCNAsP4MBHRm5Uee4xX-rCW3CW_4"
val tabName = "Favorite Cities"

import spark.implicits
val df = Seq(("Brooklyn", "New York"), 
          ("New York City", "New York"), 
          ("San Francisco", "California")).
          toDF("City", "State")

df.write.
  format("com.github.potix2.spark.google.spreadsheets").
  option("serviceAccountId", serviceAccountId).
  option("credentialPath", resourceToLocal(filePathFromResourcesDirectory)).
  save(s"${googleSheetId}/${tabName}")
Tony Fraser
fonte
2

O arquivo necessário pode ser acessado como abaixo da pasta de recursos no scala

val file = scala.io.Source.fromFile(s"src/main/resources/app.config").getLines().mkString
Dileep Dominic
fonte