小编Pri*_*mar的帖子

airflow webserver 命令失败并显示 {filesystemcache.py:224} 错误 - 不允许操作

  • 我正在 Cent OS 7 上安装 Airflow。我已经配置了 Airflow db init 并检查了 nginx 服务器的状态及其工作正常。但是当我运行airflow webserver命令时,我收到下面提到的错误*[2021-03-22 14:59:30 +0000] [9019] [INFO] Booting worker with pid: 9019 [2021-03-22 14:59:32,548] {filesystemcache.py:224} ERROR - set key '\x1b[01m__wz_cache_count\x1b[22m' -> [Errno 1] Operation not permitted: '/tmp/tmpdwzf56wm.__wz_cache' -> '/tmp/2029240f6d1128be89ddc32729463129'

python webserver nginx airflow

6
推荐指数
1
解决办法
3120
查看次数

如何在scala中写入csv文件?

我正在尝试将数据写入 csv 文件,我创建了四列

val csvFields = Array("Serial Number", "Record Type", First File value", Second file value") ', 
Run Code Online (Sandbox Code Playgroud)

除了序列号之外,其他三个字段都是列表

Second_file_value = List ("B", "gjgbn", "fgbhjf", "dfjf")
Run Code Online (Sandbox Code Playgroud)

First_File_Value = List ("A","abhc","agch","mknk")

Record_type = List('1','2',3','4');

 val outputFile = new BufferedWriter(new FileWriter("Resulet.csv")
 val csvWriter = new CSVWriter(outputFile)
 val listOfRecords = new ListBuffer[Array[String]]()
 listOfRecords :+ csvFields
Run Code Online (Sandbox Code Playgroud)

我正在使用这个循环写入列

for ( i <- 1 until 30){
listOfRecords += Array(i.toString, Record_type , First_File_Value , Second_file_value )}
csvWriter.writeAll(listOfRecords.toList)
output.close()
Run Code Online (Sandbox Code Playgroud)

我面临的问题是 csv 文件填充了 30 行相同的值(第一行值),列表中的值没有被迭代。

任何参考文献也会有帮助

java collections scala list

1
推荐指数
1
解决办法
2万
查看次数

标签 统计

airflow ×1

collections ×1

java ×1

list ×1

nginx ×1

python ×1

scala ×1

webserver ×1