Отправка данных сервером

#!/usr/bin/python
# -*- coding: utf-8 -*-
import time     # Паузы
import threading  #Потоки
import socket   # Сокет
 
 
dan_Pr = "ret" # Переменная принятых данных
 
 
# для создания потоков
def thread(my_func):
    def wrapper(*args, **kwargs):
        my_thread = threading.Thread(target=my_func, args=args, kwargs=kwargs)
        my_thread.start()
    return wrapper
 
@thread
def server1(): # Поток сервер
    while True:
        sock = socket.socket()
        sock.bind(('', 9090))
        sock.listen(100)
        conn, addr = sock.accept()
 
        print('connected:', addr)
 
        while True:
            try:
                data = conn.recv(1024)  # Считывание данных, данные БАЙТОВЫЕ
                if not data:
                    break
                #conn.send(data)  # Отправляем на сервер пришедшие данные
                global dan_Pr
                dan_Pr = data
                dan_Pr = data.decode('UTF-8')  # Преобазование байтов в текст
                obrabotka()
            except socket.error:
                pass
 
 
        conn.close()
        print("ON connected:")
        time.sleep(1)
 
 
 
def obrabotka():
    print(dan_Pr)
    if (dan_Pr == "Vmenu"):
        print("Меню пришло")
          #////////       Вюда вписать отправку текстовых данные на сервер, типа ("Меню пришло")
    elif (dan_Pr == "Vprav"):
        print("В право пришло")
 
 
server1()

#!/usr/bin/python
# -*- coding: utf-8 -*-
import time     # Паузы
import threading  #Потоки
import socket   # Сокет
 
 
dan_Pr = "ret" # Переменная принятых данных
dan_Ot = "qwe" # Переменная на отправку данных
sost_soc = False # Состояние сокета, что бы не долбилась если нет клиента
 
 
# для создания потоков
def thread(my_func):
    def wrapper(*args, **kwargs):
        my_thread = threading.Thread(target=my_func, args=args, kwargs=kwargs)
        my_thread.start()
    return wrapper
 
@thread
def server1(): # Поток сервер
    while True:
        sock = socket.socket()
        sock.bind(('', 9090))
        sock.listen(100)
        global conn
        conn, addr = sock.accept()
        global sost_soc
        sost_soc = True  #Клиент подключился
        print('connected:', addr)
 
        while True:
            try:
                global data
                data = conn.recv(1024)  # Считывание данных, данные БАЙТОВЫЕ
                if not data:
                    break
 
                global dan_Pr
                dan_Pr = data.decode('UTF-8')  # Преобазование байтов в текст, что бы отправить на обработку
                obrabotka()
 
            except socket.error:
                 pass
 
 
 
        conn.close()
        print("ON connected:")
        sost_soc = False # Клиент отключился
        time.sleep(1)   # Для препожключения клиента, иначе на raspbery неуспевает пересоздаться сокет
 
 
 
def obrabotka(): # Обработка принятых данных
    print(dan_Pr)
    if (dan_Pr == "Vmenu"):
        print("Меню пришло")
        otpr("Meny prishlo")
 
    elif (dan_Pr == "Vprav"):
        print("В право пришло")
 
def otpr(dan_Ot):  # Для отпавки, if чтобы не долбилась без клиента
    if sost_soc:
        conn.send(dan_Ot.encode('utf-8'))
 
 
 
@thread
def oty():  # Ещё один поток с таймером раз в секунду, что бы эмулировать событие отправки,
 
    while True:
        time.sleep(1)
        otpr("Meny")
 
server1() # Поток сервер
oty()  # Ещё один поток с таймером раз в секунду, что бы эмулировать событие отправки,