scala - 捕获 map 内的异常

Question

在 Scala 中迭代循环时处理异常的最佳方法是什么？

例如，如果我有 convert()可能引发异常的方法，我想捕获该异常，记录它并继续迭代。有没有一种“scala”方法可以做到这一点？

理想情况下，我想要这样的东西......

val points: Seq[Point] = ...
val convertedPoints: Seq[ConvertedPoint] = points.map(
   p => {
     try { p.convert() } 
     catch { case ex: Exception => logger.error("Could not convert", ex) }
})

您无法执行上述代码，因为它不是从一个列表到另一个列表的直接映射(您返回 Seq[Any] 而不是 Seq[ConvertedPoint] )。

Answer 1

flatMap 可能是您正在寻找的，但是 map 函数具有日志记录副作用，并且如果点是 View ，这些副作用可能不会立即发生:

val convertedPoints = points.view.flatMap { p =>
  try { 
    Some(p.convert) 
  } catch {
    case e : Exception =>
    // Log error
    None
  }
}
println("Conversion complete")
println(convertedPoints.size + " were converted correctly")

这将打印:

Conversion complete
[Error messages]
x were converted correctly

就你的情况而言，放弃 View 就可能没问题。 :)

要使转换成为纯函数(无副作用)，您可能会使用 Either。尽管我认为不值得在这里付出努力(除非您实际上想对错误做一些事情)，但这里有一个非常完整的使用它的示例:

case class Point(x: Double, y: Double) {
  def convert = {
    if (x == 1.0) throw new ConversionException(this, "x is 1.0. BAD!")
    else ConvertedPoint(x, y)
  }
}
case class ConvertedPoint(x: Double, y: Double)
class ConversionException(p: Point, msg: String) extends Exception(msg: String)


val points = List(Point(0,0), Point(1, 0), Point(2,0))

val results = points.map { p =>
  try {
    Left(p.convert)
  } catch {
    case e : ConversionException => Right(e)
  }
}

val (convertedPoints, errors) = results.partition { _.isLeft }

println("Converted points: " + convertedPoints.map(_.left.get).mkString(","))
println("Failed points: " + errors.map( _.right.get).mkString(","))