快捷導(dǎo)航

在Python的Django框架中用流響應(yīng)生成CSV文件的教程

更新時間：2015年05月02日 12:03:42 作者：豬了個去

這篇文章主要介紹了在Python的Django框架中用流響應(yīng)生成CSV文件的教程,作者特別講到了防止CSV文件中的中文避免出現(xiàn)亂碼等問題,需要的朋友可以參考下

在Django里，流式響應(yīng)StreamingHttpResponse是個好東西,可以快速、節(jié)省內(nèi)存地產(chǎn)生一個大型文件。

目前項目里用于流式響應(yīng)的一個是Eventsource，用于改善跨系統(tǒng)通訊時用戶產(chǎn)生的慢速的感覺。這個不細說了。

還有一個就是生成一個大的csv文件。

當Django進程處于gunicorn或者uwsgi等web容器中時，如果響應(yīng)超過一定時間沒有返回，就會被web容器終止掉，雖然我們可以通過加長web容器的超時時間來繞過這個問題，但是畢竟還是治標不治本。要根本上解決這個問題，Python的生成器、Django框架提供的StreamingHttpResponse這個流式響應(yīng)很有幫助

而在csv中，中文的處理也至關(guān)重要，要保證用excel打開csv不亂碼什么的。。為了節(jié)約空間，我就把所有代碼貼到一起了。。實際使用按照項目的規(guī)劃放置哈

上代碼：

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)

from django.views.generic import View
from django.http.response import StreamingHttpResponse

class ExampleView(View):
  headers=['一些','表頭']
  def get(self,request):
    result = [['第一行','數(shù)據(jù)1'],
         ['第二行','數(shù)據(jù)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

您可能感興趣的文章: