mirror of
https://gitee.com/sjqzhang/go-fastdfs.git
synced 2024-11-29 17:57:41 +08:00
43 lines
715 B
Python
43 lines
715 B
Python
# -*- coding: utf-8 -*-
|
|
import requests
|
|
|
|
import gevent
|
|
|
|
|
|
from Queue import Queue
|
|
|
|
q=Queue()
|
|
|
|
import commands
|
|
|
|
from gevent import monkey
|
|
|
|
monkey.patch_all()
|
|
import os
|
|
out=commands.getoutput('find . -type f')
|
|
|
|
lines=out.split("\n")
|
|
|
|
for i in lines:
|
|
q.put(i)
|
|
|
|
|
|
def task():
|
|
while True:
|
|
name=q.get(block=False)
|
|
if name=="":
|
|
break
|
|
url = 'http://10.1.5.20:8080/group1/upload'
|
|
files = {'file': open(name, 'rb')}
|
|
options = {'output': 'json', 'path': '', 'scene': ''}
|
|
try:
|
|
r = requests.post(url, files=files)
|
|
except Exception as er:
|
|
print(er)
|
|
|
|
th=[]
|
|
for i in range(200):
|
|
th.append(gevent.spawn(task))
|
|
gevent.joinall(th)
|
|
|