小编Sha*_*lam的帖子

我有一个shell脚本,最后一行如下:

pip install .

它有什么作用？

当我们运行时pip install package-name,它将安装指定的包.同样,当我们运行pip install -r requirements.txt它时,安装所有指定的包requirements.txt.但我不确定上面的命令是做什么的.

我想使用Google Cloud Storage API将所有文件夹放入给定的Google Cloud存储桶或文件夹中.

例如,如果gs://abc/xyz包含三个文件夹gs://abc/xyz/x1,gs://abc/xyz/x2和gs://abc/xyz/x3.API应该返回所有三个文件夹gs://abc/xyz.

它可以很容易地使用 gsutil

gsutil ls gs://abc/xyz

但我需要使用python和Google Cloud Storage API来实现.

什么可以是正则表达式匹配anystring后跟daily但它必须不匹配daily前面m？

例如,它应匹配以下字符串

• beta.daily
• abcdaily
• dailyabc
• daily

但它一定不匹配

• mdaily 要么
• abcmdaily 要么
• mdailyabc

我试过跟随和其他正则表达式,但每次失败:

• r'[^m]daily':但它与之不符 daily
• r'[^m]?daily':它与包含mdaily不符合的字符串匹配

我从事Apache Beam已有两天了。我想快速迭代正在使用的应用程序，并确保正在构建的管道没有错误。在spark中，我们可以使用sc.parallelise，当我们执行某些操作时，我们可以获得可以检查的值。

同样，当我阅读有关Apache Beam的内容时，我发现我们可以PCollection使用以下语法创建一个并使用它

with beam.Pipeline() as pipeline:
    lines = pipeline | beam.Create(["this is test", "this is another test"])
    word_count = (lines 
                  | "Word" >> beam.ParDo(lambda line: line.split(" "))
                  | "Pair of One" >> beam.Map(lambda w: (w, 1))
                  | "Group" >> beam.GroupByKey()
                  | "Count" >> beam.Map(lambda (w, o): (w, sum(o))))
    result = pipeline.run()

我实际上想将结果打印到控制台。但是我找不到关于它的任何文档。

有没有一种方法可以将结果打印到控制台，而不是每次都将其保存到文件中？

为什么以下代码的最后一行在scala REPL中引发错误？

import scala.concurrent._
import scala.concurrent.duration._
import scala.concurrent.ExecutionContext.Implicits.global

// This is okay
val futureInt = Future[Int] { 42 }
val v1 = Await.result(futureInt, 1.second)

// This throw error: java.lang.NoClassDefFoundError: Could not initialize class $line8.$read$$iw$$iw$$iw$$iw$$iw$$iw$
val v2 = Await.result(Future[Int]{ 42 }, 1.second)

但是，当我创建一个主类并执行相同的代码时，它可以正常工作：

import scala.concurrent._
import scala.concurrent.duration._
import scala.concurrent.ExecutionContext.Implicits.global

object Main {
  def main(args: Array[String]): Unit = {
    val futureInt = Future[Int] { 42 }
    val v1 = Await.result(futureInt, 1.second)
    val v2 = Await.result(Future[Int] { 44 }, 1.second)
    println(s"v1=$v1, v2=$v2 ") …