python/Read_Binary_File.py at master · wonderfan/python · GitHub

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
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
frompymongoimportMongoClient
frompymongoimportMongoReplicaSetClient
frombson.objectidimportObjectId
frompymongo.read_preferencesimportReadPreference
importbase64
frombson.binaryimportBinary

definit_schema_data(db=None):

collection_credential=db['credential']
user= {"user_name":"wonderfan","role":"cloud_change_manager","user_password":"aq1sw2de"}
collection_credential.insert(user)

collection_subscription=db['subscription']
subscription= {"ci_id":"abd","ci_short_name":"C14","ci_description":"development environment","offering_item":"LA_CLOUD","item_quality":"1","from_appdirect":"N","appdirect_account":"","appdirect_subscription_id":"","CFTS_customer_number":"","CFTS_country_code":"","CFTS_contract_number":"","CFTS_company_code":"","create_ts":"2014-08-15","start_billing_ts":"2014-08-15","end_billing_ts":""}
collection_subscription.insert(subscription)

collection_history=db['subscription_process_history']
process_history= {"subscription_id":"","user_id":"","process_ts":"2014-08-15","process_type":"create_new_cloud_instance"}
collection_history.insert(process_history)

collection_cloud_instance=db['cloud_instance']
cloud_instance= {"ci_short_name":"C14","ci_description":"development environment","change_manager_id":""}
collection_cloud_instance.insert(cloud_instance)

collection_check_point=db['check_point']
check_point= {"check_ts":"2014-08-15","period_start_ts":"","period_end_ts":"","subscription_id":"","ci_id":"","ci_short_name":"","ci_description":"","offering_item":"LA_CLOUD","item_quantity":"1","from_appdirect":"N","appdirect_account":"","appdirect_subscription_id":"","CFTS_customer_number":"","CFTS_country_code":"","CFTS_contract_number":"","CFTS_company_code":"","start_billing_ts":"2014-08-15","end_billing_ts":"","period_usage_start_ts":"2014-08-15","period_usage_end_ts":"2014-09-15","period_usage_total":"31","period_usage_uom":"day"}
collection_check_point.insert(check_point)

defdb_operation(db=None):
print"CRUD operations";

if__name__=="__main__":

importjson

printjson.load(open('phone.png'))
importsys
sys.exit(0)

print"Start the MongoDB connection"
flag=False
client=MongoClient("127.0.0.1",27017)
db=client['deployment_db']
test=db.test
record=test.find()
file_name='test.xml'
withopen(file_name,"rb") asfd:
content=base64.b64encode(fd.read())
record= {"_id":"test","date":"2014-10-15","data":content}
ret_value=test.save(record)

db_record=test.find_one({"_id":"test"})

importjson
printjson.dumps(db_record,indent=4)
importsys
sys.exit()

withopen("new.png","wb") asfw:
fw.write(db_record['data'].decode('base64'))
fw.close()


"""
	print content
	import xmltodict
	content = xmltodict.parse(content)
	print content
	"""


"""
	if flag:
 init_schema_data(db)
	else:
 db_operation(db)
	"""
client.close()
print"End the MongoDB connection"