python

Differences

This shows you the differences between two versions of the page.

Link to this comparison view

Next revision 		Previous revision
python [2021/08/11 10:52]
wikiadmin created 		python [2024/09/19 15:57] (current)
wikiadmin
Line 3: Line 3:
 Most of the complexity is removed by the definitions you created in TransSECS.  Most of the complexity is removed by the definitions you created in TransSECS. 
  
-The python wrapper uses the [[JPype|https://pypi.org/project/JPype1/]] library to directly interface with the Java code. +The python wrapper uses the [[https://pypi.org/project/JPype1/|JPype]] library to directly interface with the Java code.
  
- +For the tool,copy the GEMToolRuntime.jar from the TransSECS GEMTool project into the build folder
-Message notifications are received as JSON maps so that each of the published elements in the message are available directly.+
  
 For the host,copy the GEMHostRuntime.jar from the TransSECS GEMHost project into the build folder For the host,copy the GEMHostRuntime.jar from the TransSECS GEMHost project into the build folder
  
-The samples, even though simple, demonstrates all the features required of a tool and the ability to collect data from a host. +The sample, demonstrates all the features required to build a tool.  It can be extended to include any features available in the Java host or tool.
- +
-In the host code, publish variables you need to change in the interface, here the port, hostname, deviceid, etc. and subscribe to elements to receive data updates.  Here an event (loaded) and to values (ppid and wafer count).  The event is received as a JSON structure. +
  
-For example, to set the hostname, you publish to that variable: +Here's the code sample from the python wrapper archive:
- +
-<code rust> +
-    wrapper.publish_string("gemhost/configuration/equipmenthostname", "localhost").unwrap(); +
-</code> +
- +
- +
-And Events (CEIDs) received as JSON Strings that contains the values configured in TransSECS.  For example, a subscription to the "loaded" event might deliver a JSON string similar to this: +
- +
-<code javascript> +
- { "LOADED": [  { "RPTID103": [ {"LOTID":"", "type":20 },{"PPID":"recipename", "type":20 },{"WaferCount":"1", "type":54 } ], "rptid":103} ], "ceid":7503, "timestamp":"2021-08-10 19:58:28.802"} +
-</code> +
- +
-The sample code receives and unpacks that structure: +
-  +
-<code rust> +
-    wrapper.subscribe("gemhost/variables/ceid/loaded", |topic,value| { +
-        println!("Callback called on {}:", topic); +
-        if let Value::String(string_value) = value.value { +
-            // The ceid appears as a json object, which we can parse for example with serde_json +
-            let parsed:LoadedCeid = serde_json::from_str(&string_value).unwrap(); +
-            // We'll just immediately reserialize the json to demonstrate that we have the fields +
-            println!("{}", serde_json::to_string_pretty(&parsed).unwrap()); +
-        } +
-    }).unwrap(); +
-</code> +
-The tool can subscribe to be notified of the change in value of any VID - used for ECIDs and GEM internal variables: +
- +
-<code rust> +
-    wrapper.subscribe("gemhost/variables/vid/lotid", |topic,value| { +
-        println!("Callback called on {} with {:?}", topic, value) +
-    }).unwrap(); +
-</code> +
- +
-Here's the code sample from the rustwrapper archive:+
  
 <code python> <code python>
Line 57: Line 20:
 from jpype.types import * from jpype.types import *
  
-jpype.startJVM(classpath=['.', '/home/colin/TransSECS_Servers_2/Projects/GEMHost/GEMHostDeployment/GEMHostRuntime.jar', '/home/colin/TransSECS_Servers_2/Projects/GEMHost/generatedjars/GEMHost.jar', '/home/colin/Documents/workspace-spring-tool-suite-4-4.2.2.RELEASE/MIStudio/vib/vib/lib/json-20190722.jar', '/home/colin/Documents/workspace-spring-tool-suite-4-4.2.2.RELEASE/MIStudio/classes'])+jpype.startJVM(classpath=['.', './GEMToolRuntime.jar'])
  
 from com.ergotech.util import SimulationManager from com.ergotech.util import SimulationManager
-from deploy.GEMHost import EquipmentController+from deploy.GEMTool import EquipmentController, HostCommandReply 
 +from com.ergotech.transsecs.secs.gem import GemHandler 
 +from com.ergotech.vib.valueobjects import DoubleValueObject, LongValueObject, StringValueObject
  
 import time import time
 +import random
  
-hostname =  "localhost"+# Configuration
 port = 5010 port = 5010
 deviceid = 1 deviceid = 1
 +online = 1  # Online state
 +remote = 1  # Remote state
  
 +# Initialize the equipment controller
 SimulationManager.getSimulationManager().setSimulating(False) SimulationManager.getSimulationManager().setSimulating(False)
- +equipment = EquipmentController() 
-host = EquipmentController() +host.setPort(port)
-host.setEquipmentHostName(hostname) +
-host.setActivePort(port)+
 host.setDeviceId(deviceid) host.setDeviceId(deviceid)
 host.init() host.init()
 host.start() host.start()
  
-def event_received(ceid, event_report_values): +# Set initial VID values 
- print("Event received: " + str(ceid) + " with values:\n" + str(event_report_values))+host.setIntValue(33006, online)  # Go Online 
 +host.setIntValue(33005, remote)  # Allow Local-Remote transition
  
-d = {'eventReceived': event_received } +# Get the gemHandler for setting VID values using names 
-listener_proxy = JProxy("com.ergotech.transsecs.secs.host.EventListener", dict=d)+gemHandler = controller.getGemHandler() 
 +gemHandler.setValue("MDLN", StringValueObject("Test 123  456")) 
 +gemHandler.setValue("WaferCount", LongValueObject(1))
  
-# Add a listener for all events +# Example of setting OnlineOfflineState using VID name 
-host.setGlobalEventListener(listener_proxy)+gemHandler.setValue("OnlineOfflineState", LongValueObject(1)) 
 + 
 +# Get data source container for accessing VIDs (this may need additional jars/classes) 
 +# container = DataSourceContainer.getRootContainer().getContainer("GEMTool") 
 + 
 +# Event and Alarm setup 
 +gemEvent = gemHandler.getServerForName("CEID.Completed") 
 +alarm = gemHandler.getServerForName("ALID.TemperatureProblem") 
 + 
 +# Host Command START Notifier 
 +class HostCommandSTARTNotifier: 
 +    def messageReceived(self, status, message): 
 +        print(f"Message Received in Host Command START Notifier: {message}") 
 +        hostCommand = message 
 +        command = hostCommand.getCommand() 
 +        print(f"Host Command is {command}") 
 +        if command != "START": 
 +            print("Host Command Rejected") 
 +            self.sendErrorResponse(1)  # 1 = bad command 
 +            return 
 + 
 +        print("Host Command START Accepted") 
 +        self.sendOKResponse() 
 + 
 +    def sendErrorResponse(self, hcack): 
 +        connection = GemIDConnection.createConnection("GEMTool") 
 +        response = connection.getController().getMessageBean("HostCommandReply") 
 +        response.setHCACK([hcack]) 
 +        response.sendMessage() 
 + 
 +    def sendOKResponse(self): 
 +        connection = GemIDConnection.createConnection("GEMTool") 
 +        response = connection.getController().getMessageBean("HostCommandReply") 
 +        response.sendMessage() 
 + 
 +# Register the notifier 
 +notifier_proxy = JProxy("com.ergotech.transsecs.secs.host.MessageNotifier", inst=HostCommandSTARTNotifier()) 
 +controller.registerForReceiveNotification("HostCommandSTART", notifier_proxy) 
 + 
 +print("Simple GEM Tool set up on Port 5010 and Device ID 1") 
 + 
 +# Main loop to change some SVID values and trigger alarms/events periodically 
 +cycles = 0 
 +waferCount = 0 
 +alarm_set = False
  
 while True: while True:
-    print('GEMHost running...') +    cycles += 1 
-    time.sleep(10)</code>+    # Update process variables 
 +    gemHandler.setValue("ProcessTemperature", DoubleValueObject(random.random() * 10 + 120.0)) 
 +    gemHandler.setValue("GasFlow", DoubleValueObject(random.random() * 1 + 1)) 
 + 
 +    # Increment the wafer count every 20 cycles 
 +    if cycles % 20 == 0: 
 +        waferCount += 1 
 +        gemHandler.setValue("WaferCount", LongValueObject(waferCount)) 
 + 
 +    # Trigger the event every 120 cycles 
 +    if cycles % 120 == 0: 
 +        gemEvent.setBooleanValue(True) 
 +        print("Event Triggered") 
 +    else: 
 +        gemEvent.setBooleanValue(False) 
 + 
 +    # Check for alarm conditions 
 +    temperature = gemHandler.getServerForName("VID.ProcessTemperature").getFloatValue() 
 +    if temperature > 128.5 and not alarm_set: 
 +        alarm.set() 
 +        alarm_set = True 
 +        print("Alarm Triggered") 
 +    elif alarm_set: 
 +        alarm.clear() 
 +        alarm_set = False 
 +        print("Alarm Cleared") 
 + 
 +    # Wait for next cycle 
 +    time.sleep(0.5) 
 +</code>
  • python.1628697161.txt.gz
  • Last modified: 2021/08/11 10:52
  • by wikiadmin