An interface to intercept operator commands START, STOP,MODFY for Python programs on z/OS, and to write to the operator console
- ftp zconsole.pax.bin to z/OS in binary, to a directory in the PYTHONPATH environment variable.
- pax -rvf zconsole.pax.bin
This will produce
- zconsole.so - the load module
- console.py - a class for running the code
- cons3.py - an example python script for running as a started task which demonstrates all of the functions.
import zconsole as zconsole zconsole.put("This gets written to the z/OS console") zconsole.put("This gets written to the z/OS console using descr and route",desc=11,route=2) You can use the C run time _console2 but this will prefix your message with BPX... if the userid is not authrorised to BPX.CONSOLE and is not a super userid with uid(0).
zconsole.console2("This gets written to the z/OS console") zconsole.console2("This gets written to the z/OS console using descr and route",desc=11,route=2) An operator can issue commands like
- s PYT,,,'COLINs Data',p=CONSNEW
- STOP PYT
- F PYT,'pass a parameter while running'
To use this you need
exit_flag = threading.Event() a =console.console() a.cb(ccp,[exit_flag]) This will call the callback function ccp passing the parameters within the [].
It uses console.py which has a class defined within it. This is done, so the class object can use the atexit.register. This registers a function to be run at shutdown time. This function then cancels the asynchronous thread. If this is not done, then the main thread may just hang, or it may abend, saying an attached subtask is still running.
This returns data to the call back funtion like (for the Start Command)
{'rc': 0, 'verb': 'Start', 'data': '', 'console': 'IBMUSER ', 'cart': b'\xc9\xe2\xc6\xdb\xc3\x00\xaf;', 'consoleid': b'\x03\x00\x00\x0c\x00\xfb8\xc0', 'oconsoleid': b'\x03\x00\x00\x0c\x00\xfb8\xc0' } and for a modify command
{'rc': 0, 'verb': 'Modify', 'data': "'ddd'", ... } and from the stop command
{'rc': 0, 'verb': 'Stop', 'data': ' ', ... } // PROC P='cons2' //* // SET PY='/usr/lpp/IBM/cyp/v3r8/pyz/bin/python3' // SET PR='/u/tmp/console' //* //STEP1 EXEC PGM=BPXBATSL,REGION=0M,TIME=NOLIMIT,MEMLIMIT=NOLIMIT, // PARM='PGM &PY &PR/&P..py' //STDOUT DD SYSOUT=* //STDERR DD SYSOUT=* //SYSDUMP DD SYSOUT=* //CEEDUMP DD SYSOUT=* //STDIN DD DUMMY Start this JCL to use cons3.py using
S PYT,p='cons3' import zconsole as zconsole import console as console import atexit as atexit from datetime import datetime import time from threading import Timer import sys from threading import Event import threading import concurrent.futures def ccp(args,a ) : global stop # set this to 1 to stop global global_counter # increment this x = zconsole.taskinfo() print("ccp Task info ",x) e = args[1] # [functionName,[parms]) e = e[0] # event with threadLock: global_counter += 1 print("qedit output",a) # display what we received if a["verb"] == "Stop": stop = 1 e.set() # post event - wake up main - This uses a global flag (stop) to tell the main thread that "STOP" was issued
- It also updates a counter, using a threadLock, to ensure there no timing window
- It prints the output
stop = 0 global_counter = 0 print("START",flush=True) threadLock = threading.Lock() exit_flag = threading.Event() a =console.console() a.put("Colins write to console") a.put("Output from put,with desc=11 and route=2",desc=11,route=2) a.console2("Write using __console2") a.console2("Write using __console2 desc=11, rout2=2") # set up the call back - passing the routine, and the threading event a.cb(ccp,[exit_flag]) print("MAIN taskinfo ",zconsole.taskinfo()) for i in range (0,4 ): exit_flag.wait(timeout=30) # did we time out? if (exit_flag.is_set() == False): break print("POST ",datetime.utcnow().strftime('%Y-%m-%d %H:%M:%S.%f'),flush=True) exit_flag.clear() print("GlobalCounter",global_counter) print("stop",stop) if stop == 1: break print("after stop ",stop) - s PYT,p='cons3'
- f PYT,2oLIN D3ta
- p PYT
This starts, the Python script as a started task. It is passed some data, it is told to shutdown.
START MAIN taskinfo {'jobname': 'PYT ', 'ascb': '0x00fbed00', 'tcb': '0x008d5e88', 'tcbttime': 0} ccp Task info {'jobname': 'PYT ', 'ascb': '0x00fbed00', 'tcb': '0x008d5cf0', 'tcbttime': 0} qedit output {'rc': 0, 'verb': 'Start', 'data': '', 'console': 'IBMUSER ', 'cart': ... POST 2022-07-27 10:00:42.631067 GlobalCounter 1 stop 0 ccp Task info {'jobname': 'PYT ', 'ascb': '0x00fbed00', 'tcb': '0x008d5cf0', 'tcbttime': 0} qedit output {'rc': 0, 'verb': 'Modify', 'data': '2OLIN D3TA', 'console': 'IBMUSER ', 'cart': ... POST 2022-07-27 10:00:46.886143 GlobalCounter 2 stop 0 ccp Task info {'jobname': 'PYT ', 'ascb': '0x00fbed00', 'tcb': '0x008d5cf0', 'tcbttime': 0} qedit output {'rc': 0, 'verb': 'Stop', 'data': ' ', 'console': 'IBMUSER ', 'cart': ... POST 2022-07-27 10:00:50.948860 GlobalCounter 3 stop 1 after stop 1