直接用phpexcel就可以了，不建议用csv

CSVWriter在我写入数据时未将数据保存到文件

Python新手对csv模块感到有点沮丧。以这种速度，如果我自己编写文件解析器会更容易，但是我想用Pythonic的方式做事情。

我写了一个小python脚本，应该将我的数据保存到CSV文件中。

这是我的代码片段：

import csvwrtr = csv.writer(open(''myfile.csv'',''wb''),delimiter='','', quotechar=''"'')for row in rows:    wrtr.writerow([row.field1,row.field2,row.field3])

文件myfile.csv已成功创建，但为空-但已锁定，因为Python进程仍在使用它。似乎数据已写入内存中的文件，但尚未刷新到磁盘。

由于Python进程在文件上持有锁，因此我假设我负责释放锁。这是我的问题：

1. 我如何让python刷新到磁盘
2. 如何关闭在csv.writer（）方法中打开的文件？

答案1

采用

with open(''myfile.csv'',''wb'') as myfile:    wrtr = csv.writer(myfile, delimiter='','', quotechar=''"'')    for row in rows:        wrtr.writerow([row.field1,row.field2,row.field3])        myfile.flush() # whenever you want

要么

myfile = open(''myfile.csv'',''wb'')wrtr = csv.writer(myfile, delimiter='','', quotechar=''"'')for row in rows:    wrtr.writerow([row.field1,row.field2,row.field3])    myfile.flush() # whenever you want, and/ormyfile.close() # when you''re done.

第一种方法的好处是，在发生异常的情况下，文件也会自动正确关闭。

如果您希望文件对象是匿名的，则仅在程序退出时将其关闭。什么时候刷新或是否刷新取决于操作系统-因此可能永远不会退出。

flinksql怎么将数据写入到文件中

本篇内容主要讲解“flinksql怎么将数据写入到文件中”，感兴趣的朋友不妨来看看。本文介绍的方法操作简单快捷，实用性强。下面就让小编来带大家学习“flinksql怎么将数据写入到文件中”吧!

package com.jd.dataoutput;

import com.jd.data.SensorReading;
import org.apache.flink.api.common.functions.MapFunction;
import org.apache.flink.streaming.api.datastream.DataStreamSource;
import org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
import org.apache.flink.table.api.DataTypes;
import org.apache.flink.table.api.Table;
import org.apache.flink.table.api.bridge.java.StreamTableEnvironment;
import org.apache.flink.table.descriptors.FileSystem;
import org.apache.flink.table.descriptors.OldCsv;
import org.apache.flink.table.descriptors.Schema;

public class FlinksqlOutputFile {
    public static void main(String[] args) throws Exception {
        StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
        env.setParallelism(1);
        DataStreamSource<String> stream = env.readTextFile("/Users/liuhaijing/Desktop/flinktestword/aaa.txt");
//        DataStreamSource<String> stream = env.socketTextStream("localhost", 8888);

        SingleOutputStreamOperator<SensorReading> map = stream.map(new MapFunction<String, SensorReading>() {

            public SensorReading map(String s) throws Exception {
                String[] split = s.split(",");
                return new SensorReading(split[0], split[1], split[2]);
            }
        });



        StreamTableEnvironment tableEnv = StreamTableEnvironment.create(env);
//        使用 table api
        Table table = tableEnv.fromDataStream(map);
//        table.printSchema();
        Table select = table.select("a,b");
//        select.printSchema();

//        使用 sql api
//        tableEnv.createTemporaryView("test", map);
//        Table select = tableEnv.sqlQuery(" select a, b from test");
//        select.printSchema();


//        DataStream<SensorReading2> sensorReading2DataStream = tableEnv.toAppendStream(select, SensorReading2.class);
//        sensorReading2DataStream.map(new MapFunction<SensorReading2, Object>() {
//            @Override
//            public Object map(SensorReading2 value) throws Exception {
//                System.out.println(value.a+"   "+ value.b);
//                return null;
//            }
//        });

//        tableEnv.connect(new FileSystem().path("/Users/liuhaijing/IdeaProjects/haijing3/spark/flinksqldemo/output/out.txt"))
//                .withFormat(new Csv())
//                .withSchema(
//                        new Schema()
//                                .field("a", DataTypes.STRING())
//                                .field("b", DataTypes.STRING()))
//                .inAppendMode()
//                .createTemporaryTable("outputTable");
//        select.insertInto("outputTable");


        tableEnv.connect(new FileSystem().path("/Users/liuhaijing/IdeaProjects/haijing3/spark/flinksqldemo/output/out.txt"))
                .withFormat(new OldCsv())
                .withSchema(new Schema()
                                .field("a", DataTypes.STRING())
                ).inAppendMode()
                .createTemporaryTable("outputTable");
        select.insertInto("outputTable");

        env.execute();




    }
}

到此，相信大家对“flinksql怎么将数据写入到文件中”有了更深的了解，不妨来实际操作一番吧！这里是小编网站，更多相关内容可以进入相关频道进行查询，关注我们，继续学习！

我们今天的关于将数据写入 CSV 文件和将数据写入csv文件python的分享已经告一段落，感谢您的关注，如果您想了解更多关于7、flinksql 将数据写入到文件中、CodeIgniter3.1 利用CSV批量导入功能将数据写入数据库、CSVWriter在我写入数据时未将数据保存到文件、flinksql怎么将数据写入到文件中的相关信息，请在本站查询。