将JSON文件上载到Amazon SQ时出错

Question

我有下面的代码，它基本上尝试向SQS写入一个.json文件

import json
import uuid
import time
import boto.sqs
import boto
from boto.sqs.connection import SQSConnection
from boto.sqs.message import Message
from boto.sqs.message import RawMessage

sqs = boto.sqs.connect_to_region("ap-southeast-1")
queue = sqs.get_queue("Demon")
json_fileone=open('emp.json')  ## this is only one JSON file 
dataone=json.load(json_fileone)

print dataone
[queue.write(queue.new_message(i)) for i in dataone]
print "File sent successfully to queue"

这将上载所需的emp.json文件文件，我需要做的是对文件数量运行一个循环，因为我有emp1.json、emp2.json、emp3.json、emp4.json到SQS，默认情况下BOTO在发送之前执行BASE64编码。。。我需要以相同的格式发送这些文件，即'.json'

Answer 1

根据您的问题和我们的评论，您需要使用glob。在

import glob
json_files = glob.glob("*.json")
for json_file in json_files: 
    process_file(json_file)

因此，将您的进程移动到函数process_file。同时使用with语句处理文件。在

^{pr2}$