2

Below there is some fully functioning code.

I am planning to execute this code through command line, however I would like it to end after 60 seconds.

Does anyone know the best way of going about this?

Thanks in advance. 

import time class listener(StreamListener): def on_data(self, data): try: print data saveFile = open('twitDB.csv','a') saveFile.write(data) saveFile.write('\n') saveFile.close() return True except BaseException, e: print 'failed ondata,' ,str(e) time.sleep(5) def on_error(self, status): print status
Improve this question
8
  • 1
    Memorize the time when it started, query the time in on_data and exit if one minutes has passed? Commented Dec 25, 2013 at 18:26
  • Is 'import time' at the beginning is memorising the time? Also I cant find the code for querying the time... Commented Dec 25, 2013 at 18:30
  • 1
    This is just a class definition. It would not "run from the command line". Do you mean from the python interpreter? Commented Dec 25, 2013 at 19:10
  • do not catch BaseException unless you reraise it later. Why do you want to ignore SystemExit or KeyboardInterrupt? Commented Dec 25, 2013 at 19:38
  • Basically I want the code to run for one minute every hour, I thought I would code in the cancel after 60 seconds first and then look at using command line so the code ran every hour. Would this not be correct? Commented Dec 25, 2013 at 19:39

5 Answers 5

Reset to default
3

Try this out:

import os import time from datetime import datetime from threading import Timer def exitfunc(): print "Exit Time", datetime.now() os._exit(0) Timer(5, exitfunc).start() # exit in 5 seconds while True: # infinite loop, replace it with your code that you want to interrupt print "Current Time", datetime.now() time.sleep(1)

There are some more examples in this StackOverflow question: Executing periodic actions in Python

I think the use of os._exit(0) is discouraged, but I'm not sure. Something about this doesn't feel kosher. It works, though.

Improve this answer
Sign up to request clarification or add additional context in comments.

9 Comments

The code will run fine, with the above inserted however the end function doesn't end.
Try it now, os._exit(0) exits like you would want it to.
Running for 5 seconds so were getting there, :D
No something has gone wrong where by now it's just printing the date repeatedly.
@user3102640: os._exit() is a nuclear option but it works. See also How to exit the entire application from a Python thread?
|
3

You could move your code into a daemon thread and exit the main thread after 60 seconds:

#!/usr/bin/env python import time import threading def listen(): print("put your code here") t = threading.Thread(target=listen) t.daemon = True t.start() time.sleep(60) # main thread exits here. Daemon threads do not survive.
Improve this answer

11 Comments

failed ondata, global name 'listen' is not defined is the error message I get
@user3102640: I've updated the code. Let me know if something is not clear.
I keep getting error with syntax here: ` print("put your code here")` @J.F Sebastian
@user3102640: the code works as is on Python 2 and Python 3. Make sure the copy-paste process hasn't added Unicode whitespace into the code (just delete whitespace before print and type 4 spaces manually).
That's quite neat, @J.F.Sebastian.
|
0

Use signal.ALARM to get notified after a specified time.

import signal, os def handler(signum, frame): print '60 seconds passed, exiting' cleanup_and_exit_your_code() # Set the signal handler and a 60-second alarm signal.signal(signal.SIGALRM, handler) signal.alarm(60) run_your_code()

From your example it is not obvious what the code will exactly do, how it will run and what kind of loop it will iterate. But you can easily implement the ALARM signal to get notified after the timeout has expired.

Improve this answer

2 Comments

I get this error message failed ondata, 'module' object has no attribute 'SIGALRM'
@user: signal.SIGALRM won't work on some platform e.g., Windows.
0

This is my favorite way of doing timeout.

def timeout(func, args=None, kwargs=None, TIMEOUT=10, default=None, err=.05): if args is None: args = [] elif hasattr(args, "__iter__") and not isinstance(args, basestring): args = args else: args = [args] kwargs = {} if kwargs is None else kwargs import threading class InterruptableThread(threading.Thread): def __init__(self): threading.Thread.__init__(self) self.result = None def run(self): try: self.result = func(*args, **kwargs) except: self.result = default it = InterruptableThread() it.start() it.join(TIMEOUT* (1 + err)) if it.isAlive(): return default else: return it.result
Improve this answer

5 Comments

This is a modification of the code found here. code.activestate.com/recipes/473878
You don't actually interrupt func(*args, **kwargs) call. It continues to run whether the timeout happened or not. Moreover misnamed "InterruptableThread" is not a daemon. It will prevent the program to exit if func() is still running.
@J.F.Sebastian How would you make this work using a daemon so that func() would timeout then? In other words, could you modify your answer so that if could take a function and arguments like my answer tries to do?
@J.F.Sebastian How would I be able to get the results to output using that syntax? I haven't been able to figure that out still.
@J.F.Sebastian Basically, I am still looking for a valid answer to this question that I asked, stackoverflow.com/q/20360795/2246694 that would incorporate daemon
-1

I hope this is an easy way to execute a function periodically and end after 60 seconds:

import time import os i = 0 def executeSomething(): global i print(i) i += 1 time.sleep(1) if i == 10: print('End') os._exit(0) while True: executeSomething()
Improve this answer

Comments

Start asking to get answers

Find the answer to your question by asking.

Ask question

Explore related questions

See similar questions with these tags.