{"id":140,"date":"2021-02-27T14:34:00","date_gmt":"2021-02-27T14:34:00","guid":{"rendered":""},"modified":"2023-12-18T12:12:47","modified_gmt":"2023-12-18T12:12:47","slug":"much-improved-pi-assistant-message-reader","status":"publish","type":"post","link":"https:\/\/doctor-dark.co.uk\/blog\/much-improved-pi-assistant-message-reader\/","title":{"rendered":"Much improved Pi Assistant message reader."},"content":{"rendered":"
The most important improvement is that this program now works… \ud83d\ude0e <\/span><\/div>\n

<\/span><\/div>\n
I just leave it running on the Pi Assistant, along with the Google provided <\/span>assistant_library_with_button_demo.py<\/b> program that I like to use, when I want to ask the Google Assistant something…<\/span><\/span><\/div>\n

<\/span><\/div>\n
\n
#!\/usr\/bin\/python3<\/span><\/div>\n
#<\/span><\/div>\n
# Program to run on PiAssistant, to watch for newly arrived text files in<\/span><\/div>\n
# \/home\/pi\/Messages that it should speak, and delete them once it has.<\/span><\/div>\n
import os<\/span><\/div>\n
import paramiko<\/span><\/div>\n
import time<\/span><\/div>\n

<\/span><\/div>\n
path = “\/home\/pi\/Messages\/”<\/span><\/div>\n

<\/span><\/div>\n
while True:<\/span><\/div>\n
    with os.scandir(path) as entries:<\/span><\/div>\n
        for entry in entries:<\/span><\/div>\n
            f = open(entry, “r”)<\/span><\/div>\n
            content = f.read()<\/span><\/div>\n
            f.close()<\/span><\/div>\n
            command = “python ~\/AIY-projects-python\/src\/aiy\/voice\/tts.py “” + <\/span><\/div>\n
                      content + “” –lang en-GB –volume 10 –pitch 60 –speed 90″<\/span><\/div>\n
            os.system(command)<\/span><\/div>\n
            os.remove(path+entry.name)      <\/span><\/div>\n
            # Now wait for tts.py to finish<\/span><\/div>\n
            command = “ps -ef | grep -v grep | grep “voice.tts” | wc -l”<\/span><\/div>\n
            while True:<\/span><\/div>\n
                ssh_stdin, ssh_stdout, ssh_stderr = ssh.exec_command(command)<\/span><\/div>\n
                answer = str(ssh_stdout.read())<\/span><\/div>\n
                if answer[2] == “0”:<\/span><\/div>\n
                break           <\/span><\/div>\n
            time.sleep(0.5)<\/span><\/div>\n
    time.sleep(0.5)<\/span><\/div>\n

<\/span><\/div>\n
And here is a program to run on a cluster of Raspberry Pi computers, as say_who.py<\/b>, which will each send a message to the Pi Assistant, from each core of the processor. The assistant will read them out, separately. It does seem still to lose some messages, and if I work out why, I will let you know! <\/span>I have been searching for simple example programs for Raspberry Pi clusters on the internet for ages, and have not found very many. Here’s my little gift…<\/span><\/span><\/div>\n

<\/span><\/div>\n
<\/p>\n
#!\/usr\/bin\/python3<\/div>\n
from mpi4py import MPI<\/div>\n
import os<\/div>\n
import time<\/div>\n
import subprocess as sp<\/div>\n
<\/div>\n
# Attach to the cluster and find out who I am and what my rank is<\/div>\n
comm = MPI.COMM_WORLD<\/div>\n
my_rank = comm.Get_rank()<\/div>\n
cluster_size = comm.Get_size()<\/div>\n
my_host = os.popen(‘cat \/etc\/hostname’).read().strip()<\/div>\n
    <\/div>\n
# Make something for the assistant to say<\/div>\n
speech = “Host is  {} “.format(my_host)<\/div>\n
speech = speech + “Rank {} “.format(my_rank)<\/div>\n
<\/div>\n
# Make a unique filename and path<\/div>\n
message = “\/home\/pi\/” + my_host + str(my_rank)<\/div>\n
          + time.strftime(“%H%M%S”) + “.txt”<\/div>\n
# Put the speech in the file<\/div>\n
fp = open(message,”x”)<\/div>\n
fp.write(speech)<\/div>\n
fp.close()<\/div>\n
<\/div>\n
# Put a copy of the file on PiAssistant<\/div>\n
cmd = “scp ” + message + ” pi@PiAssistant:\/home\/pi\/Messages\/”<\/div>\n
sp.call(cmd,shell=True)<\/div>\n
os.remove(message)<\/div>\n
<\/div>\n
You would load that program on each of the Pi machines in your cluster, and then set it running using the command<\/span><\/div>\n

<\/span><\/div>\n
mpiexec -n 16 -hostfile myhostfile python3 say_who.py<\/b><\/span><\/div>\n

<\/b><\/span><\/div>\n
\n
I’m assuming you have four Pi 3 machines in the cluster, hence the -n 16<\/b> parameter. <\/span><\/div>\n

<\/span><\/div>\n<\/div>\n
#RaspberryPi #Cluster #Python <\/span><\/div>\n

<\/span><\/div>\n<\/div>\n","protected":false},"excerpt":{"rendered":"

The most important improvement is that this program now works… \ud83d\ude0e  I just leave it running on the Pi Assistant, along with the Google provided assistant_library_with_button_demo.py program that I like to use, when I want to ask the Google Assistant something… #!\/usr\/bin\/python3 # # Program to run on PiAssistant, to watch for newly arrived text files … Continue reading “Much improved Pi Assistant message reader.”<\/span><\/a><\/p>\n","protected":false},"author":1,"featured_media":0,"comment_status":"closed","ping_status":"closed","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[7],"tags":[],"class_list":["post-140","post","type-post","status-publish","format-standard","hentry","category-raspberry-pi"],"jetpack_featured_media_url":"","_links":{"self":[{"href":"https:\/\/doctor-dark.co.uk\/blog\/wp-json\/wp\/v2\/posts\/140","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/doctor-dark.co.uk\/blog\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/doctor-dark.co.uk\/blog\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/doctor-dark.co.uk\/blog\/wp-json\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/doctor-dark.co.uk\/blog\/wp-json\/wp\/v2\/comments?post=140"}],"version-history":[{"count":1,"href":"https:\/\/doctor-dark.co.uk\/blog\/wp-json\/wp\/v2\/posts\/140\/revisions"}],"predecessor-version":[{"id":349,"href":"https:\/\/doctor-dark.co.uk\/blog\/wp-json\/wp\/v2\/posts\/140\/revisions\/349"}],"wp:attachment":[{"href":"https:\/\/doctor-dark.co.uk\/blog\/wp-json\/wp\/v2\/media?parent=140"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/doctor-dark.co.uk\/blog\/wp-json\/wp\/v2\/categories?post=140"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/doctor-dark.co.uk\/blog\/wp-json\/wp\/v2\/tags?post=140"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}