{"id":122,"date":"2020-02-23T20:26:42","date_gmt":"2020-02-23T19:26:42","guid":{"rendered":"http:\/\/www.w2hp.net\/wp\/?page_id=122"},"modified":"2020-02-23T20:26:42","modified_gmt":"2020-02-23T19:26:42","slug":"paramiko-mqtt","status":"publish","type":"page","link":"https:\/\/wp.w2hp.net\/?page_id=122","title":{"rendered":"Paramiko + Mqtt"},"content":{"rendered":"

import threading, paramiko
from paramiko_expect import SSHClientInteraction
import socket
import paho.mqtt.client as mqtt
<\/code><\/p>\n


class ssh:
shell = None
client = None
transport = None<\/p>\n

# PROMPT= '$'
PROMPT = 'wehner@tmo:~\\$\\s+'
def on_connect(self, client, userdata, flags, rc):
print(\"Connected with result code \"+str(rc))
# Subscribing in on_connect() means that if we lose the connection and
# reconnect then subscriptions will be renewed.
self.mqttclient.subscribe(\"test\/#\")<\/p>\n

def on_message(self ,client, userdata, msg):
print(msg.topic+\" \"+str(msg.payload))
if( msg.topic ==\"test\/abc\"):
tmp1=str(msg.payload)[1:]
tmp1=tmp1.strip(\"'\")<\/p>\n

words=tmp1.split()
tmp1=words.pop(0)
if tmp1.lower()== \"command\" :
tmp1=\" \"
tmp2=tmp1.join(words)
print(tmp2)
with SSHClientInteraction(self.client, timeout=10, display=True) as interact:
interact.send(tmp2 + '\\n')
interact.expect(self.PROMPT, timeout=500)
cmd_output_uname = interact.current_output_clean
print (\"output who\" , cmd_output_uname , \"ohw\")<\/p>\n

def __init__(self, address, username, password):
print(\"Connecting to server on ip\", str(address) + \".\")
self.client = paramiko.client.SSHClient()
self.client.set_missing_host_key_policy(paramiko.client.AutoAddPolicy())
self.client.connect(address,port=66, username=username, password=password, look_for_keys=False)
self.transport = paramiko.Transport((address, 66))
self.transport.connect(username=username, password=password)
self.mqttclient = mqtt.Client()
self.mqttclient.on_connect = self.on_connect
self.mqttclient.on_message = self.on_message<\/p>\n

self.mqttclient.connect(\"localhost\", 1883, 60)<\/p>\n

self.mqttclient.loop_start()
thread = threading.Thread(target=self.process)
thread.daemon = True
thread.start()<\/p>\n

def closeConnection(self):
if(self.client != None):
self.client.close()
self.transport.close()<\/p>\n

def openShell(self):
self.shell = self.client.invoke_shell()
with SSHClientInteraction(self.client, timeout=10, display=True) as interact:
interact.expect(self.PROMPT)
cmd_output_uname = interact.current_output_clean
print (\"cc1\" , cmd_output_uname , \"ccc1\")
interact.send('who\\n')
interact.expect(self.PROMPT, timeout=500)
cmd_output_uname = interact.current_output_clean
print (\"output who\" , cmd_output_uname , \"ohw\")<\/p>\n

def sendShell(self, command):
if(self.shell):
self.shell.send(command + \"\\n\")
else:
print(\"Shell not opened.\")<\/p>\n

def process(self):
global connection
while True:
# Print data when available
if self.shell != None and self.shell.recv_ready():
alldata = self.shell.recv(1024)
while self.shell.recv_ready():
alldata += self.shell.recv(1024)
strdata = str(alldata, \"utf8\")
strdata.replace('\\r', '')
print(strdata, end = \"\")
if(strdata.endswith(\"$ \")):
print(\"\\n$ \", end = \"\")<\/p>\n

sshUsername = \"user\"
sshPassword = \"passwd\"
sshServer = socket.gethostbyname(\"tmo.net\") #\"93.206.206.186\"<\/p>\n

connection = ssh(sshServer, sshUsername, sshPassword)
connection.openShell()<\/p>\n

while True:
command = input('$ ')
if command.startswith(\" \"):
command = command[1:]
connection.sendShell(command)
<\/code><\/p>\n<\/p><\/div>\n","protected":false},"excerpt":{"rendered":"

import threading, paramikofrom paramiko_expect import SSHClientInteractionimport socketimport paho.mqtt.client as mqtt class ssh: shell = None client = None transport = None # PROMPT= ‚$‘ PROMPT = ‚wehner@tmo:~\\$\\s+‘ def on_connect(self, client, userdata, flags, rc): print(„Connected with result code „+str(rc)) # Subscribing in on_connect() means that if we lose the connection and # reconnect then subscriptions will … <\/p>\n

\u201eParamiko + Mqtt\u201c<\/span> weiterlesen<\/a><\/p>\n","protected":false},"author":1,"featured_media":0,"parent":0,"menu_order":0,"comment_status":"closed","ping_status":"closed","template":"","meta":{"ngg_post_thumbnail":0,"footnotes":""},"class_list":["post-122","page","type-page","status-publish","hentry"],"_links":{"self":[{"href":"https:\/\/wp.w2hp.net\/index.php?rest_route=\/wp\/v2\/pages\/122","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/wp.w2hp.net\/index.php?rest_route=\/wp\/v2\/pages"}],"about":[{"href":"https:\/\/wp.w2hp.net\/index.php?rest_route=\/wp\/v2\/types\/page"}],"author":[{"embeddable":true,"href":"https:\/\/wp.w2hp.net\/index.php?rest_route=\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/wp.w2hp.net\/index.php?rest_route=%2Fwp%2Fv2%2Fcomments&post=122"}],"version-history":[{"count":1,"href":"https:\/\/wp.w2hp.net\/index.php?rest_route=\/wp\/v2\/pages\/122\/revisions"}],"predecessor-version":[{"id":123,"href":"https:\/\/wp.w2hp.net\/index.php?rest_route=\/wp\/v2\/pages\/122\/revisions\/123"}],"wp:attachment":[{"href":"https:\/\/wp.w2hp.net\/index.php?rest_route=%2Fwp%2Fv2%2Fmedia&parent=122"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}