mdsthin 1.4.1

MDSplus Thin-Client implemented in pure python

mdsthin - Python MDSplus Thin Client Implementation

This package provides the types and functions needed to interface with MDSplus over thin client. This contains most of the functionality from the regular MDSplus C/Python package, but does not map perfectly. If you are migrating from the regular package, or plan to support both, see Full MDSplus Package Compatability.

What is thin client?
Thin allows access to MDSplus through TDI expressions, using the Connection class in python, or mdsconnect/mdsvalue in our other APIs.

Installation

python3 -m pip install mdsthin

Examples

See the examples folder.

Experimental Features

See Experimental.md for more information.

Tests

You can run the full test suite with:

python3 -m mdsthin.test [-v] [--server SERVER] [--cmod]

Or use it from a python prompt

from mdsthin import test

test.run_mdsthin_tests(server='SERVER')

Usage

import mdsthin

Connect to a server

# Connect over MDSip
c = mdsthin.Connection('server')

# Specify a custom username and port for MDSplus
c = mdsthin.Connection('username@server:8123')

# Connect over SSH
c = mdsthin.Connection('ssh://server')
c = mdsthin.Connection('sshp://server')

# Using a with statement
with mdsthin.Connection('server') as c:
    ...
    # c.disconnect() will be called automatically

For more information on how to use MDSip over SSH, see Advanced SSH Usage

Run TDI expressions

c.get('whoami()').data() # "username"

c.get('getenv("HOSTNAME")').data() # "server"

# Using argument substitution
c.get('4 + $', 5) # 9Q

Run TCL commands

print(c.tcl('show current test'))
# Current shot is 123

# Create a new pulse
c.tcl('set tree test /shot=-1')
c.tcl('create pulse 123')

This is just a wrapper function around the TDI Tcl() function.

Open/Close Trees

# Open the current shot
c.openTree('test', 0)

# Open or close a specific shot
c.openTree('test', 123)
c.closeTree('test', 123)

# Close all open trees
c.closeAllTrees()

Read data from nodes

You will want to call .data() on the result of almost every .get() command. When you call .get() you will retrieve the MDSplus type, such as Int32 or Float32Array. When you call .data() on these objects, you get the native numpy data type such as numpy.int32 or numpy.ndarray(dtype='float32').

c.openTree('test', 0)

# Read individual nodes
y = c.get('SIGNAL_NODE').data()
x = c.get('dim_of(SIGNAL_NODE)').data()

# Read multiple nodes at the same time
gm = c.getMany()
gm.append('y', 'SIGNAL_NODE')
gm.append('x', 'dim_of(SIGNAL_NODE)')
gm.execute()

y = gm.get('y').data()
x = gm.get('x').data()

# Read the entire object
sig = c.getObject('SIGNAL_NODE').data()
y = sig.data()
x = sig.dim_of()

# Read data from tags
ip = c.get('\\IP').data()

# Read data from nodes inside other nodes
freq = c.get('HARDWARE.DEVICE.FREQUENCY')
seglen = c.get('HARDWARE.DEVICE.SEGLEN')
amp = c.get('HARDWARE.DEVICE.AMPLITUDE')

# Or set the default node to make this easier
# (This is similar to the `cd` shell command)
c.setDefault('HARDWARE.DEVICE')

freq = c.get('FREQUENCY')
seglen = c.get('SEGLEN')
amp = c.get('AMPLITUDE')

# Reset the default back to the top
c.setDefault('\\TOP')

Writing data into nodes

c.openTree('test', -1)

# Using a TDI expression
c.put('HARDWARE.DEVICE.FREQUENCY', '10000.')

# Using a python type
c.put('HARDWARE.DEVICE.FREQUENCY', '$', 10000.0)

# Using an explicit MDSplus type
c.put('HARDWARE.DEVICE.FREQUENCY', '$', mdsthin.Float32(10000.0))

# Writing to multiple nodes at once
pm = c.putMany()
pm.append('HARDWARE.DEVICE.FREQUENCY', '$', 10000.0)
pm.append('HARDWARE.DEVICE.SEGLEN', '$', 8000)
pm.append('HARDWARE.DEVICE.AMPLITUDE', '$', 5.0)
pm.execute()

# Writing objects using TDI expressions
c.put('INIT_THING', 'Build_Action(Build_Dispatch(0, "THING", "INIT", 50, ""), do_thing(), "")')

# Writing objects using serialize
from mdsthin import *
init_action = Action(Dispatch(0, 'THING', 'INIT', 50, ''), EXT_FUNCTION(None, 'do_thing'), '', )
c.put('INIT_THING', 'SerializeIn($)', init_action.serialize())

A remote mdstcl prompt using mdsthin.mdstcl

This will let you run TCL commands and view their output.

Unfortunately, command history is not supported 🙁.

python3 -m mdsthin.mdstcl SERVER
Connectiong to: SERVER
TCL> show current test
123
TCL> exit

Or use it from a python prompt

import mdsthin
c = mdsthin.Connection('server')

c.mdstcl()
TCL> show current test
123
TCL> exit

Or use it over ssh with all of the options available in Advanced SSH Usage, see the --help page for details.

This can be very useful to interactively work with a tree. Note: any trees you open will affect the entire connection, and calling set default xyz will have the same effect as calling c.setDefault('xyz').

A remote tdic prompt using mdsthin.tdic

This will let you run TDI expressions and view their output.

Unfortunately, command history is not supported 🙁.

python3 -m mdsthin.tdic SERVER
Connectiong to: SERVER
TDI> 4 + 5
9L
TDI> exit

Or use it from a python prompt

import mdsthin
c = mdsthin.Connection('server')

c.tdic()
TDI> 4 + 5
9L
TDI> exit

Or use it over ssh with all of the options available in Advanced SSH Usage, see the --help page for details.

Full MDSplus Package Compatability

For those coming from the regular MDSplus package, or who want to ensure they do not use functionality from mdsthin that is not present in the regular MDSplus package, we provide a subpackage called MDSplus.

This provides a better mapping to the regular MDSplus package by:

• Adding functions to approximate functionality missing in mdsthin
• Removing types/functions not present in the regular MDSplus package
• Aliasing types that are not directly present in mdsthin

from mdsthin import MDSplus

c = MDSplus.Connection('server')

i = Uint32(42)

MDSplus.mdsExceptions.checkStatus(265388200)

If you encounter code that should work with this package but doesn't, please create an issue and we'll do our best to provide compatability.

Advanced SSH Usage

There are two methods of SSH supported, ssh:// and sshp://, as well as two SSH backends, subprocess and paramiko. You can use any method with any backend, and the default is subprocess.

ssh:// - Connect using mdsip-server-ssh

Using this protocol will attempt to spawn /bin/sh -l -c mdsip-server-ssh on the remote server, and then use that as the MDSip server.

Note: This will fail if you do not source the MDSplus setup.sh on login, or if it cannot find mdsip-server-ssh on the $PATH.

# This will run `ssh server "/bin/sh -l -c mdsip-server-ssh"`
c = mdsthin.Connection('ssh://server')

# Specify a custom username for MDSplus and SSH
c = mdsthin.Connection('ssh://username@server')

# Specify a custom port for SSH
c = mdsthin.Connection('ssh://server', ssh_port=2222)

# For backwards compatability with regular MDSplus, you can also use
c = mdsthin.Connection('ssh://server:2222')

sshp:// - Connect using nc $sshp_host $port

Using this protocol will attempt to spawn ssh $host -p $ssh_port and then nc $sshp_host $port on the remote server, and then use that to proxy to the MDSip server.

# This will run `ssh server "nc localhost 8000"`
c = mdsthin.Connection('sshp://server')

# Specify a custom username for MDSplus and SSH
c = mdsthin.Connection('sshp://username@server')

# Specify a custom port for SSH
# This will run `ssh server -p2222 "nc localhost 8000"`
c = mdsthin.Connection('sshp://server', ssh_port=2222)

# Specify a custom port for MDSip
# This will run `ssh server "nc localhost 8123"`
c = mdsthin.Connection('sshp://server:8123')

# Specify a custom host for MDSip
# This will run `ssh proxy-server "nc server 8000"`
c = mdsthin.Connection('sshp://proxy-server', sshp_host='server')

# All together now!
# This will run `ssh proxy-server -p2222 "nc server 8123"`
c = mdsthin.Connection('sshp://proxy-server:8123',
    ssh_port=2222, sshp_host='server')

Using the subprocess backend

This backend uses the subprocess package to Popen an ssh subprocess. This will then connect to the server and run the command specified by your protocol (ssh:// or sshp://, see above) and attach to the stdin/stdout to communicate with the server.

# This is the default if not specified
c = mdsthin.Connection('ssh://server')

# You can also specify it explicitly
c = mdsthin.Connection('ssh://server', ssh_backend='subprocess')

# Specify additional SSH command line options
c = mdsthin.Connection('ssh://server',
    ssh_subprocess_args=['-i', '/path/to/private/key'])

When using the subprocess backend on Windows, you can force the use of plink.exe instead of ssh.exe by passing ssh_use_plink=True. However, you will very likely need to pass ssh_subprocess_args to inform plink.exe of your SSH key location.

# Attempt to use plink.exe instead of ssh.exe
c = mdsthin.Connection('ssh://server', ssh_use_plink=True)

# Pass a Putty SSH Key (PPK) to plink.exe
c = mdsthin.Connection('ssh://server', ssh_use_plink=True,
    ssh_subprocess_args=['-i', '/path/to/private/key.ppk'])

Using the paramiko backend

This backend uses the paramiko package to create an SSHClient and connect() to the server. This will then run the command specified by your protocol (ssh:// or sshp://, see above) and attach to the stdin/stdout to communicate with the server. This could be useful in a pure-python environment, or if there are concerns about executing subprocesses.

If you are unsure, go with the default subprocess.

# Specify the `paramiko` backend
c = mdsthin.Connection('ssh://server', ssh_backend='paramiko')

# Specify additional kwargs to paramiko's `connect()` function
import paramiko
key = paramiko.RSAKey.from_private_key_file("/path/to/private/key")

c = mdsthin.Connection('ssh://server', ssh_backend='paramiko',
    ssh_paramiko_options={ 'pkey': key })