Das deutsche Python-Forum

Code: Alles auswählen

#!/usr/bin/env python
 #  import part

# globals
__version__ = '0.1g'
sched = BackgroundScheduler()
jobs = []   # store scheduled tasks

def jobs_listing(exit_event, name, calling):
   try:
      while not exit_event.is_set():   # loop to keep scheduler alive
	  updateJobsListing()   #  updating 'jobs', .. 
          sleep(10)       # this runs every 10 sec

   finally:
       print (' piScheduler - Exit >{0}<'.format(name))

def job_serve(exit_event, name):
    try:
        while True:
        #     doing stuff and 
        #     waiting for condition to leave try using 'break'
           break

    except:
       pass

    finally:
        #     closing part
        exit_event.set()
        listener.close()
        sched.shutdown()
        sys.exit(0)

# for web.py
urls = (
    '/', 'index'
)

# for web.py
class index:
    def GET(self, globals()):
        x =  ("hello this is RPI on .16\n")
        x1 =  __version__ + "  " +  str(datetime.datetime.now())[:19]
        #    >>>>>> no access to changed values like 'jobs' <<<<<<
        return x + x1

def main():
    #     initializing with parameter
    sched.start()  # start the scheduler
    exit_event = Event()  # define an event to allow keyboard interrupt and other
    Thread(target=jobs_listing, args=(exit_event, 'pilight Jobs', calling)).start()
    #     use web.py to get the scheduler data on a web page 
    app = web.application(urls, globals())
    app.run()

    #    a routine to read the schedule data, update 'jobs' 
    #    and kick the RPI functions
    job_serve(exit_event, 'piScheduler')

    #    close down after exit_event was set true
    sched.shutdown()
    exit()

#---------------------------------
if __name__ == "__main__":
    main()

Code: Alles auswählen

def job_serve(exit_event, name):
    address = (192.168.178.xxx, 6001)
 #    listener = Listener(address, authkey='secret password')
    listener = Listener(address')

    try:
        while True:
            connection = listener.accept()
            print (name, str(connection))
            message = connection.recv().strip()     <<<<<< error line
            #
            # process the incoming message...
            #
            print (' .... incoming msg: ', message)
    except:
       pass

    finally:
        # abgesang 

Code: Alles auswählen

address = (server, port)
conn = Client(address)
conn.send(message)

Code: Alles auswählen

xSchedule <read-write Connection, handle 6>
Traceback (most recent call last):
  File "xSchedule.py", line 572, in <module>
    main()
  File "xSchedule.py", line 564, in main
    job_serve(exit_event, 'xSchedule')
  File "xSchedule.py", line 446, in job_serve
    message = connection.recv().strip()
MemoryError

Code: Alles auswählen

if len(sys.argv) == 2:
    message = sys.argv[1]
else:
    message = 'pyClient : ' + str(datetime.datetime.now())

address = (server, 6001)
conn = Client(address, authkey='secret password')
conn.send(message)
conn.close()

Code: Alles auswählen

@route('/send_message', method='POST')
def send_message():
    message = request.params['message']
    if not message:
        message = 'pyClient : {0}'.format(datetime.datetime.now())
    address = (server, 6001)
    conn = Client(address, authkey='secret password')
    conn.send(message)
    conn.close()

    return {}

Code: Alles auswählen

@route('/send_message', method='POST')
def send_message():
    message = request.params['message']
    if not message:
        message = 'pyClient : {0}'.format(datetime.datetime.now())
    address = (server, 6001)
    conn = Client(address, authkey='secret password')
    conn.send(message)
    conn.close()

    return {}