Bluemix の Cloudant に csv ファイルを python でアップロード

こちらで curl で行ったことを、python3 で書いてみました。

Bluemix の Cloudant に csv ファイルをアップロードする

csv のアップロード

go_create.py

#! /usr/bin/python
# -*- coding: utf-8 -*-
#
#
import sys
import json
import requests
# --------------------------------------------------------------------
sys.stderr.write("*** 開始 ***\n")
url="https://44b508dd-346a-44c8-85b7-79d184aaf02f-bluemix:[e-mail]"
#
url_csv = url + "/csv"
rr=requests.delete(url_csv)
print(rr)
print(str(rr.content,'utf-8'))
#
rr=requests.put(url_csv)
print(rr)
print(str(rr.content,'utf-8'))
#
#
csv_in="cities.csv"
fp_in = open (csv_in,encoding='utf-8')
str_out = fp_in.read ()
fp_in.close ()
#
url_csv_file = url + "/csv/tochigi/cities.csv"
payload = {'send': str_out}
files = {'file': open(csv_in, 'rb')}
headers = {'Content-type': 'text/plain; charset=utf-8'}
rr=requests.put(url_csv_file, files=files,headers=headers)
print(rr)
print(str(rr.content,'utf-8'))
#
sys.stderr.write("*** 終了 ***\n")
# --------------------------------------------------------------------

CSV　の　ダウンロード

go_get.py

! /usr/bin/python
# -*- coding: utf-8 -*-
#
#   go_get.py
#
#                   Jul/27/2017
import sys
import requests
# --------------------------------------------------------------------
def filter_save(file_out,str_in):
    fp_out = open(file_out,mode='w',encoding='utf-8')
    print("*** filter_save *** start ***")
    lines=str_in.split()
    sys.stderr.write ("len(str_in) = %d\n" % len(str_in))
    sys.stderr.write ("len(lines) = %d\n" % len(lines))
    for line in lines:
        if ',' in line:
#           print(line)
            fp_out.write(line + "\n")
    fp_out.close()
    print("*** filter_save *** end ***")
# --------------------------------------------------------------------
sys.stderr.write("*** 開始 ***\n")
url="https://44b508dd-346a-44c8-85b7-79d184aaf02f-bluemix:[e-mail]"
#
file_csv="cities.csv"
#
url_csv = url + "/csv/tochigi/" + file_csv
rr=requests.get(url_csv)
print(rr)
bbx=rr.content
str_aa=str(bbx,'utf-8')
#
filter_save(file_csv,str_aa)
#
sys.stderr.write("*** 終了 ***\n")
# --------------------------------------------------------------------