擅长:python、mysql、java
<p>你可以用<a href="https://pypi.python.org/pypi/Pebble" rel="nofollow">Pebble</a>来做这个。在</p>
<pre><code>from pebble.process import concurrent
TIMEOUT_IN_SECONDS = 5
feed = connect2database()
for data in feed.changes():
data = process(data)
concurrent(target=ftpUpload, args=(data, ), timeout=TIMEOUT_IN_SECONDS)
</code></pre>