个人工具

“UbuntuHelp:BroadcastAlertWithSound”的版本间的差异

来自Ubuntu中文

跳转至: 导航, 搜索
第29行: 第29行:
 
This is the text that needs to be copied into bcast.py ..
 
This is the text that needs to be copied into bcast.py ..
 
<pre><nowiki> #!/usr/bin/python
 
<pre><nowiki> #!/usr/bin/python
 +
 
# Author: David Collins, 2007
 
# Author: David Collins, 2007
 
# Note: Changing values in os.environ does not affect calling process's environment
 
# Note: Changing values in os.environ does not affect calling process's environment
 +
 
"""
 
"""
 
Broadcast a pop-up message to X and NX sessions.  A .wav can be specified to
 
Broadcast a pop-up message to X and NX sessions.  A .wav can be specified to
 
send sound with the message, but this will only be received by NX sessions.
 
send sound with the message, but this will only be received by NX sessions.
 +
 
Usage: sudo ./bcast.py --message "message" [--title "title"] [--timeout secs]
 
Usage: sudo ./bcast.py --message "message" [--title "title"] [--timeout secs]
[--sound "wavefile.wav"]
+
                                        [--sound "wavefile.wav"]
 
"""
 
"""
 +
 
import os, subprocess, sys, getopt, string
 
import os, subprocess, sys, getopt, string
 +
 
# -------------------------------------------------------------
 
# -------------------------------------------------------------
 
def usage(msg=None):
 
def usage(msg=None):
sys.stdout = sys.stderr
+
  sys.stdout = sys.stderr
if msg != "":
+
  if msg != "":
print msg
+
    print msg
print <u>doc</u>
+
  print __doc__
sys.exit(2)
+
  sys.exit(2)
 
# -------------------------------------------------------------
 
# -------------------------------------------------------------
 
def processargs():
 
def processargs():
global title, message, wavefile, timeout
+
  global title, message, wavefile, timeout
# Default values ..
+
 
title = "Alert"
+
  # Default values ..
message = ""
+
  title = "Alert"
wavefile = ""
+
  message = ""
timeout = 0
+
  wavefile = ""
optionlist = [[UbuntuHelp:message=","title=","timeout=","sound=|message=","title=","timeout=","sound=]]
+
  timeout = 0
try:
+
 
opts, args = getopt.getopt(sys.argv[1:], "", optionlist)
+
  optionlist = ["message=","title=","timeout=","sound="]
if len(opts) < 1:
+
  try:
raise getopt.error, ""
+
    opts, args = getopt.getopt(sys.argv[1:], "", optionlist)
except getopt.error, msg:
+
    if len(opts) < 1:
usage(msg)
+
      raise getopt.error, ""
try:
+
  except getopt.error, msg:
for opt, val in opts:
+
    usage(msg)
if val[0:2] == "--":  # 2 options with no value between
+
 
raise Exception, "Option '" + opt + "' has no associated value."
+
  try:
# print opt, "=", val
+
    for opt, val in opts:
if opt == "--message":
+
      if val[0:2] == "--":  # 2 options with no value between
message = val
+
        raise Exception, "Option '" + opt + "' has no associated value."
elif opt == "--title":
+
      # print opt, "=", val
title = val
+
      if opt == "--message":
elif opt == "--sound":
+
        message = val
wavefile = val
+
      elif opt == "--title":
elif opt == "--timeout":
+
        title = val
try:
+
      elif opt == "--sound":
timeout = string.atoi(val)
+
        wavefile = val
except:
+
      elif opt == "--timeout":
raise Exception, "Timeout value '" + val + "' is not an integer."
+
        try:
except Exception, msg:
+
          timeout = string.atoi(val)
usage(msg)
+
        except:
for arg in args:
+
          raise Exception, "Timeout value '" + val + "' is not an integer."
print "***" + arg
+
  except Exception, msg:
 +
    usage(msg)
 +
 
 +
  for arg in args:
 +
    print "***" + arg
 
# -------------------------------------------------------------
 
# -------------------------------------------------------------
 
def checkdependancies():
 
def checkdependancies():
# Make sure that gxmessage is available ..
+
  # Make sure that gxmessage is available ..
# PIPE was not defined - so used -1
+
  # PIPE was not defined - so used -1
p = subprocess.Popen(['which gxmessage'], stdout=-1, shell=True)
+
  p = subprocess.Popen(['which gxmessage'], stdout=-1, shell=True)
result = p.wait()
+
  result = p.wait()
if result != 0:
+
  if result != 0:
print "Gxmessage needs to be installed."
+
    print "Gxmessage needs to be installed."
print "On ubuntu, run 'sudo apt-get install gxmessage'."
+
    print "On ubuntu, run 'sudo apt-get install gxmessage'."
exit(-2)
+
    exit(-2)
# Make sure that esdplay is available ..
+
 
p = subprocess.Popen(['which esdplay'], stdout=-1, shell=True)
+
  # Make sure that esdplay is available ..
result = p.wait()
+
  p = subprocess.Popen(['which esdplay'], stdout=-1, shell=True)
if result != 0:
+
  result = p.wait()
print "esdplay is not installed - therefore sound will not function."
+
  if result != 0:
print "On ubuntu, run 'sudo apt-get install esound' to enable sound."
+
    print "esdplay is not installed - therefore sound will not function."
 +
    print "On ubuntu, run 'sudo apt-get install esound' to enable sound."
 
# -------------------------------------------------------------
 
# -------------------------------------------------------------
 
def sendalerts():
 
def sendalerts():
# To hold list of displays - to avoid duplication.
+
  # To hold list of displays - to avoid duplication.
displaylist = []
+
  displaylist = []
# Get PID list in /proc ..
+
 
pidlist = os.listdir("/proc")
+
  # Get PID list in /proc ..
for pid in pidlist:
+
  pidlist = os.listdir("/proc")
# All number directories are PIDs ..
+
  for pid in pidlist:
if pid.isdigit():
+
 
try:
+
    # All number directories are PIDs ..
envfile = "/proc/" + str(pid) + "/environ"
+
    if pid.isdigit():
env = open(envfile)
+
      try:
environ = env.readline()
+
        envfile = "/proc/" + str(pid) + "/environ"
except:
+
        env = open(envfile)
pass  #readenv=False
+
        environ = env.readline()
else:
+
      except:
# print envfile
+
        pass  #readenv=False
envlist = environ.split("\0")
+
      else:
# print len(envlist)
+
        # print envfile
espeaker = ""
+
        envlist = environ.split("\0")
display = ""
+
        # print len(envlist)
user = ""
+
 
shlvl = ""
+
        espeaker = ""
# Get $USER, $DISPLAY, $HOME, $ESPEAKER ..
+
        display = ""
for en in envlist:
+
        user = ""
if en[0:5] == "USER=":
+
        shlvl = ""
user = en[5:]
+
 
# Skip, if this is a system process ..
+
        # Get $USER, $DISPLAY, $HOME, $ESPEAKER ..
if (user == "root") or (user.isdigit()):
+
        for en in envlist:
break
+
          if en[0:5] == "USER=":
if en[0:8] == "DISPLAY=":
+
            user = en[5:]
display = en[8:]
+
            # Skip, if this is a system process ..
os.environ['DISPLAY'] = display
+
            if (user == "root") or (user.isdigit()):
elif en[0:5] == "HOME=":
+
              break
home = en[5:]
+
          if en[0:8] == "DISPLAY=":
os.environ['HOME'] = home
+
            display = en[8:]
elif en[0:9] == "ESPEAKER=":
+
            os.environ['DISPLAY'] = display
espeaker = en[9:]
+
          elif en[0:5] == "HOME=":
os.environ['ESPEAKER'] = espeaker
+
            home = en[5:]
subprocess.Popen(['export ESPEAKER'], shell=True)
+
            os.environ['HOME'] = home
elif en[0:6] == "SHLVL=":
+
          elif en[0:9] == "ESPEAKER=":
shlvl = en[6:]
+
            espeaker = en[9:]
try:
+
            os.environ['ESPEAKER'] = espeaker
# Some filtering ..
+
            subprocess.Popen(['export ESPEAKER'], shell=True)
# eg. exclude $DISPLAY=nx/nx,options=/home/sinead/.nx/C-Buddy-1001 ..
+
          elif en[0:6] == "SHLVL=":
if (display.find(",") != -1):
+
            shlvl = en[6:]
continue
+
 
# eg. exclude $DISPLAY=:1.0
+
        try:
if (display[0] == ":"):
+
          # Some filtering ..
continue
+
          # eg. exclude $DISPLAY=nx/nx,options=/home/sinead/.nx/C-Buddy-1001 ..
# Add .0 - eg. unix:1000->unix:1000.0 (else get duplication)
+
          if (display.find(",") != -1):
if (display.find(".") == -1):
+
            continue
display=display + ".0"
+
          # eg. exclude $DISPLAY=:1.0
except:
+
          if (display[0] == ":"):
continue
+
            continue
# Send Popup Message to User's Screen using gxmessage ..
+
          # Add .0 - eg. unix:1000->unix:1000.0 (else get duplication)
# Use shlvl to identify real users (for example, excludes gdm)
+
          if (display.find(".") == -1):
# Shell=True is important - else doesn't work ..
+
            display=display + ".0"
if (user != "") and (display != "") and (shlvl != ""):
+
        except:
try:
+
          continue
# Only send to the display if it hasn't already been done.
+
 
result=displaylist.index(display)
+
        # Send Popup Message to User's Screen using gxmessage ..
except:
+
        # Use shlvl to identify real users (for example, excludes gdm)
if (espeaker != "") and (wavefile != ""):
+
        # Shell=True is important - else doesn't work ..
print "%s - Display='%s' Speaker='%s'" % (user, display, espeaker)
+
        if (user != "") and (display != "") and (shlvl != ""):
else:
+
          try:
print "%s - Display='%s'" % (user, display)
+
            # Only send to the display if it hasn't already been done.
subprocess.Popen(['sudo -u ' + user + ' gxmessage -center ' \
+
            result=displaylist.index(display)
+ '-timeout ' + str(timeout) + ' -display ' + display \
+
          except:
+ ' -title "' + title + '" "' + message + '"'], shell=True)
+
            if (espeaker != "") and (wavefile != ""):
# If user's session supports ESD sound - eg. an NX session and
+
              print "%s - Display='%s' Speaker='%s'" % (user, display, espeaker)
# a wave file is specified, play a sound/music, also ..
+
            else:
if (espeaker != "") and (wavefile != ""):
+
              print "%s - Display='%s'" % (user, display)
subprocess.Popen(['sudo -u ' + user + ' esdplay ' + wavefile],
+
 
shell=True)
+
            subprocess.Popen(['sudo -u ' + user + ' gxmessage -center ' \
# Register this display as alerted.
+
              + '-timeout ' + str(timeout) + ' -display ' + display \
displaylist.append(display)
+
              + ' -title "' + title + '" "' + message + '"'], shell=True)
 +
 
 +
            # If user's session supports ESD sound - eg. an NX session and
 +
            # a wave file is specified, play a sound/music, also ..
 +
            if (espeaker != "") and (wavefile != ""):
 +
              subprocess.Popen(['sudo -u ' + user + ' esdplay ' + wavefile],
 +
                                                        shell=True)
 +
 
 +
            # Register this display as alerted.
 +
            displaylist.append(display)
 
# -------------------------------------------------------------
 
# -------------------------------------------------------------
 
# Do it ! ...
 
# Do it ! ...

2007年12月6日 (四) 10:07的版本

This page describes how to send pop-up messages to NX and X-windows sessions. With the NX sessions, these messages can be accompanied by sound. This was developed using Ubuntu 7.04 (Feisty).

Introduction

The Python script below was developed to send pop-up messages with sound to NX and X sessions running on a Ubuntu server. This was developed on a home network consisting of a Ubuntu 7.04 server running FreeNX, and Windows PCs and Ubuntu/Xubuntu PCs running the nomachine NX client or X-Windows. The NX clients are configured to support sound, but the X-windows clients receive only a silent pop-up message.

Dependancies

The script uses gxmessage to send the pop-up messages, and esdplay to transmit a .wav sound file. Gxmessage is a requirement to run the script. Esound needs to be installed if sound functionality is required.

sudo aptitude install gmessage
sudo aptitude install esound

Setting up NX Sessions for Sound

This section is not required to get the script running without sound. If you want to get the script running quickly, you can skip this section, and come back to it later. Follow the FreeNX instructions to install FreeNX on a Ubuntu server. Ensure that esound is installed (see above), and that the esd service is running like so ..

ps -e | grep 'esd'
17249 ?        00:00:00 esd

Download the 'NX Client DEB for Linux' or 'NX client for Windows' from http://www.nomachine.com/download.php and install on your Ubuntu and Windows PCs. In the configuration of the NX client, click on the 'Services' tab, and tick 'Enable Multimedia Support' - this enables sound for the NX client. Each user needs to log onto your Ubuntu server using their NX client, and start System/Preferences/Sound from the panel. They need to choose 'ESD - Enlightened Sound Daemon' for the various sound options. They can test the sound while making these selections.

Creating and Running the Script

Copy the script code below into a file called bcast.py. Ensure that this script is executable by using the chmod command.

chmod 755 bcast.py

The script needs to be run using the sudo prefix if you are not logged in as root.

sudo ./bcast --message "Message" --title "Title" --timeout 0 --sound "wavefile.wav"

The script can be called from within cron jobs that are running using the root account. This is the text that needs to be copied into bcast.py ..

 #!/usr/bin/python

# Author: David Collins, 2007
# Note: Changing values in os.environ does not affect calling process's environment

"""
Broadcast a pop-up message to X and NX sessions.  A .wav can be specified to
send sound with the message, but this will only be received by NX sessions.

Usage: sudo ./bcast.py --message "message" [--title "title"] [--timeout secs]
                                        [--sound "wavefile.wav"]
"""

import os, subprocess, sys, getopt, string

# -------------------------------------------------------------
def usage(msg=None):
  sys.stdout = sys.stderr
  if msg != "":
    print msg
  print __doc__
  sys.exit(2)
# -------------------------------------------------------------
def processargs():
  global title, message, wavefile, timeout

  # Default values ..
  title = "Alert"
  message = ""
  wavefile = ""
  timeout = 0

  optionlist = ["message=","title=","timeout=","sound="]
  try:
    opts, args = getopt.getopt(sys.argv[1:], "", optionlist)
    if len(opts) < 1:
      raise getopt.error, ""
  except getopt.error, msg:
    usage(msg)

  try:
    for opt, val in opts:
      if val[0:2] == "--":  # 2 options with no value between
        raise Exception, "Option '" + opt + "' has no associated value."
      # print opt, "=", val
      if opt == "--message":
        message = val
      elif opt == "--title":
        title = val
      elif opt == "--sound":
        wavefile = val
      elif opt == "--timeout":
        try:
          timeout = string.atoi(val)
        except:
          raise Exception, "Timeout value '" + val + "' is not an integer."
  except Exception, msg:
    usage(msg)

  for arg in args:
    print "***" + arg
# -------------------------------------------------------------
def checkdependancies():
  # Make sure that gxmessage is available ..
  # PIPE was not defined - so used -1
  p = subprocess.Popen(['which gxmessage'], stdout=-1, shell=True)
  result = p.wait()
  if result != 0:
    print "Gxmessage needs to be installed."
    print "On ubuntu, run 'sudo apt-get install gxmessage'."
    exit(-2)

  # Make sure that esdplay is available ..
  p = subprocess.Popen(['which esdplay'], stdout=-1, shell=True)
  result = p.wait()
  if result != 0:
    print "esdplay is not installed - therefore sound will not function."
    print "On ubuntu, run 'sudo apt-get install esound' to enable sound."
# -------------------------------------------------------------
def sendalerts():
  # To hold list of displays - to avoid duplication.
  displaylist = []

  # Get PID list in /proc ..
  pidlist = os.listdir("/proc")
  for pid in pidlist:

    # All number directories are PIDs ..
    if pid.isdigit():
      try:
        envfile = "/proc/" + str(pid) + "/environ"
        env = open(envfile)
        environ = env.readline()
      except:
        pass  #readenv=False
      else:
        # print envfile
        envlist = environ.split("\0")
        # print len(envlist)

        espeaker = ""
        display = ""
        user = ""
        shlvl = ""

        # Get $USER, $DISPLAY, $HOME, $ESPEAKER ..
        for en in envlist:
          if en[0:5] == "USER=":
            user = en[5:]
            # Skip, if this is a system process ..
            if (user == "root") or (user.isdigit()):
              break
          if en[0:8] == "DISPLAY=":
            display = en[8:]
            os.environ['DISPLAY'] = display
          elif en[0:5] == "HOME=":
            home = en[5:]
            os.environ['HOME'] = home
          elif en[0:9] == "ESPEAKER=":
            espeaker = en[9:]
            os.environ['ESPEAKER'] = espeaker
            subprocess.Popen(['export ESPEAKER'], shell=True)
          elif en[0:6] == "SHLVL=":
            shlvl = en[6:]

        try:
          # Some filtering ..
          # eg. exclude $DISPLAY=nx/nx,options=/home/sinead/.nx/C-Buddy-1001 ..
          if (display.find(",") != -1):
            continue
          # eg. exclude $DISPLAY=:1.0
          if (display[0] == ":"):
            continue
          # Add .0 - eg. unix:1000->unix:1000.0 (else get duplication)
          if (display.find(".") == -1):
            display=display + ".0"
        except:
          continue

        # Send Popup Message to User's Screen using gxmessage ..
        # Use shlvl to identify real users (for example, excludes gdm)
        # Shell=True is important - else doesn't work ..
        if (user != "") and (display != "") and (shlvl != ""):
          try:
            # Only send to the display if it hasn't already been done.
            result=displaylist.index(display)
          except:
            if (espeaker != "") and (wavefile != ""):
              print "%s - Display='%s' Speaker='%s'" % (user, display, espeaker)
            else:
              print "%s - Display='%s'" % (user, display)

            subprocess.Popen(['sudo -u ' + user + ' gxmessage -center ' \
              + '-timeout ' + str(timeout) + ' -display ' + display \
              + ' -title "' + title + '" "' + message + '"'], shell=True)

            # If user's session supports ESD sound - eg. an NX session and
            # a wave file is specified, play a sound/music, also ..
            if (espeaker != "") and (wavefile != ""):
              subprocess.Popen(['sudo -u ' + user + ' esdplay ' + wavefile],
                                                        shell=True)

            # Register this display as alerted.
            displaylist.append(display)
# -------------------------------------------------------------
# Do it ! ...
processargs()
checkdependancies()
sendalerts()