在Python的Django框架中用流响应生成CSV文件

来源:网络时间:2018-03-06 15:03:26

  这篇文章主要介绍了在Python的Django框架中用流响应生成CSV文件的教程,作者特别讲到了防止CSV文件中的中文避免出现乱码等问题,需要的朋友可以参考下

在Python的Django框架中用流响应生成CSV文件

  在Django里,流式响应StreamingHttpResponse是个好东西,可以快速、节省内存地产生一个大型文件。  目前项目里用于流式响应的一个是Eventsource,用于改善跨系统通讯时用户产生的慢速的感觉。这个不细说了。  还有一个就是生成一个大的csv文件。  当Django进程处于gunicorn或者uwsgi等web容器中时,如果响应超过一定时间没有返回,就会被web容器终止掉,虽然我们可以通过加长web容器的超时时间来绕过这个问题,但是毕竟还是治标不治本。要根本上解决这个问题,Python的生成器、Django框架提供的StreamingHttpResponse这个流式响应很有帮助  而在csv中,中文的处理也至关重要,要保证用excel打开csv不乱码什么的。。为了节约空间,我就把所有代码贴到一起了。。实际使用按照项目的规划放置哈  上代码:  ?

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

41

from __future__ import absolute_import

import csv

import codecs

import cStringIO

class Echo(object):

def write(self, value):

return value

class UnicodeWriter:

"""

A CSV writer which will write rows to CSV file "f",

which is encoded in the given encoding.

"""

def __init__(self, f, dialect=csv.excel, encoding="utf-8", **kwds):


# Redirect output to a queue

self.queue = cStringIO.StringIO()

self.writer = csv.writer(self.queue, dialect=dialect, **kwds)

self.stream = f

self.encoder = codecs.getincrementalencoder(encoding)()

def writerow(self, row):

self.writer.writerow([handle_column(s) for s in row])

# Fetch UTF-8 output from the queue ...

data = self.queue.getvalue()

data = data.decode("utf-8")

# ... and reencode it into the target encoding

data = self.encoder.encode(data)

# write to the target stream

value = self.stream.write(data)

# empty queue

self.queue.truncate(0)

return value

def writerows(self, rows):

for row in rows:

self.writerow(row)

  ?


1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

from django.views.generic import View

from django.http.response import StreamingHttpResponse

class ExampleView(View):

headers=['一些','表头']

def get(self,request):

result = [['第一行','数据1'],

['第二行','数据2']]

echoer = Echo()

writer = UnicodeWriter(echoer)

def csv_itertor():

yield codecs.BOM_UTF8

yield writer.writerow(self.headers)

for column in result:

yield writer.writerow(column)

response = StreamingHttpResponse(

(row for row in csv_itertor()),

content_type="text/csv;charset=utf-8")

response['Content-Disposition'

] = 'attachment;filename="example.csv"'

return response

文章内容来源于网络,不代表本站立场,若侵犯到您的权益,可联系我们删除。(本站为非盈利性质网站) 联系邮箱:9145908@qq.com