WebSphere MQ 애플리케이션에서 Python 사용하기 (한글)

typedef _int64 MQINT64;
typedef unsigned _int64 MQUINT64;

typedef long long _int64;
typedef unsigned long long _uint64;
typedef _int64 MQINT64;
typedef _uint64 MQUINT64;

import pymqi 
qmgr = pymqi.QueueManager()
putQ = pymqi.Queue(qmgr, 'QNAME')
putQ.put('Hello world!')

import pymqi 
qmgr = pymqi.QueueManager()
getQ = pymqi.Queue(qmgr, 'QNAME')
print 'Message:', getQ.get()

from pymqi import *
import sys, os
from optparse import OptionParser

usage='Usage: %s [options] QMGRNAME QNAME (MSSG | FILE_NAME) [(MSG | FILE_NAME)...]'

def main(argv=None):
    if argv is None:
      argv = sys.argv
    try:
      (options,args)=parseOptions()
      if len(args)<3:
        raise MQException(1)
      qmgrName=args[0]
      qName=args[1]
      message=args[2]
      messages=args[2:]
      #open queue in specified queue manager
      qmgr = QueueManager(qmgrName)
      putQ = Queue(qmgr, qName)
      #loop through arguments and put messages
      #to a queue
      for message in messages:
        #if -f options is specified, arguments are file names
        if options.msgIsFile==True:
          if os.path.exists(message)==False:
            raise MQException(3)
          #read file contents to a message-variable
          f=open(message)
          content=f.readlines()
          f.close()
          #variable 'content' is a list of lines in the specified file
          #join lines in content-variable together as one string
          message=''.join(content)
        
        #single method call to put message to a queue
        putQ.put(message)
        if not options.quiet==True:
          print 'Message sent.' 
    except MQException, err:
      #if exception happens, print error message and exit
      print  '[ERROR]',err.errorCodes[err.msg]
      print usage % (sys.argv[0],)
      return err.code
    except MQMIError,err:
      print err
      return -1

def parseOptions():  
  parser = OptionParser(usage=(usage % ('%prog',)))
  parser.add_option("-f", 
                    "--file", 
                    action="store_true",
                    dest="msgIsFile",
                    help="Use file specified as third argument as message .", )
  parser.add_option("-q", 
                    "--quiet", 
                    action="store_true",
                    dest="quiet",
                    help="Quiet mode.", )
  (options, args) = parser.parse_args()
  return (options, args)


#MQException class that holds application specific error codes
#and error messages
class MQException(Exception):
  errorCodes={'1': 'QMGRNAME, QNAME or MESSAGE missing.',
              '2': 'Too many arguments.',
              '3': 'File does not exist.',
              '4': 'QMGRNAME or QNAME.',
              }
  code=0
  def __init__(self, code):
    self.code=code
    self.msg = str(code)

if __name__ == "__main__":
    sys.exit(main())

Usage: PyPut.py [options] QMGRNAME QNAME (MSSG | FILE_NAME) [(MSG | FILE_NAME)...]

Options:
  -h, --help   show this help message and exit
  -f, --file   Use file specified as third argument as message .
  -q, --quiet  Quiet mode.

from pymqi import *
import sys, os
from optparse import OptionParser

usage='Usage: %s [options] QMGRNAME QNAME'
def main(argv=None):
    if argv is None:
      argv = sys.argv
    try:
      (options,args)=parseOptions()
      if len(args)>2:
        raise MQException(2)
      if len(args)<2:
        raise MQException(4)
      qmgrName=args[0]
      qName=args[1]
      
      #open queue manager and queue
      qmgr = QueueManager(qmgrName)
      Q = Queue(qmgr, qName)      
      if options.all==True:
        moreMessages=True
        while(moreMessages):
          try:
            #get single message from queue
            message=Q.get()
            printMessage(options,message)
          except MQMIError,err:
            if err.reason==2033:
              moreMessages=False
              if not options.quiet==True:
                if not options.noDelim==True:
                  print '-'*70
                print 'No messages.' 
            else:
              raise
          
      else:
        message=Q.get()
        printMessage(options,message)
    except MQException, err:
      print  '[ERROR]',err.errorCodes[err.msg]
      print usage % (sys.argv[0],)
      return err.code
    except MQMIError,err:
      if err.reason==2033:
        #no messages
        if not options.quiet==True:
          print 'No messages.' 
          
      else:
        print err
        return err.reason

def printMessage(options,message):
  if options.saveFile==True:
    seq=1
    if not options.fileName==None:
      fileName=options.fileName
    else:
      fileName='message'
      fileName='%s%05d' %(fileName,seq)
    while os.path.exists(fileName)==True:
      fileName=fileName[:-5]
      seq=seq+1
      fileName='%s%05d' %(fileName,seq)
    f=open(fileName,'w')
    f.write(message)
    f.close()
  else:
    if not options.quiet==True:
      if not options.noDelim==True:
        print '-'*70
      print message

def parseOptions():  
  parser = OptionParser(usage=(usage % ('%prog',)))
  parser.add_option("-f", 
                    "--file", 
                    action="store_true",
                    dest="saveFile",
                    help="Save message to a file with name 'message'.", )
  parser.add_option("-n", 
                    "--file-name", 
                    dest="fileName",
                    help="File name for message. Use with -f option.", )
  parser.add_option("-A", 
                    "--all", 
                    action="store_true",
                    dest="all",
                    help="Get all messages. If messages are saved to file,"+
                     " messages have sequence number in the file name.", )
  parser.add_option("-q", 
                    "--quiet", 
                    action="store_true",
                    dest="quiet",
                    help="Quiet mode.", )
  parser.add_option("", 
                    "--no-delim", 
                    action="store_true",
                    dest="noDelim",
                    help="Do not print message delimeter.", )
  
  (options, args) = parser.parse_args()
  return (options, args)

#MQException class that holds application specific error codes
#and error messages
class MQException(Exception):
  errorCodes={'1': 'QMGRNAME, QNAME or MESSAGE missing.',
              '2': 'Too many arguments.',
              '3': 'File does not exist.',
              '4': 'QMGRNAME or QNAME missing.',
              }
  code=0
  def __init__(self, code):
    self.code=code
    self.msg = str(code)
    
if __name__ == "__main__":
    sys.exit(main())

Usage: PyGet.py [options] QMGRNAME QNAME

Options:
  -h, --help            show this help message and exit
  -f, --file            Save message to a file with name 'message'.
  -n FILENAME, --file-name=FILENAME
                        File name for message. Use with -f option.
  -A, --all             Get all messages. If messages are saved to file,
                        messages have sequence number in the file name.
  -q, --quiet           Quiet mode.
  --no-delim            Do not print message delimeter.

from pymqi import *
import sys, os
from optparse import OptionParser

usage='Usage: %s [options] QMGRNAME QNAME'
def main(argv=None):
    if argv is None:
      argv = sys.argv
    try:
      (options,args)=parseOptions()
      if len(args)>2:
        raise MQException(2)
      if len(args)<2:
        raise MQException(4)
      qmgrName=args[0]
      qName=args[1]
      
      #open queue manager 
      qmgr = QueueManager(qmgrName)
      gqdesc = od( ObjectName=qName)
      Q= Queue( qmgr, gqdesc)
      qDepth=Q.inquire(CMQC.MQIA_CURRENT_Q_DEPTH)
      if options.depth==True:
        #open queue for inquire
        print 'Current depth: %d' % qDepth
        return 0

      if not options.index==None:
        if int(options.index)>=qDepth:
          raise MQException(5)

      #open queue for browsing
      Q= Queue( qmgr, gqdesc, CMQC.MQOO_BROWSE)
      msgDesc = md()
      getOpts = gmo(Options = CMQC.MQGMO_BROWSE_NEXT)
      getOpts.WaitInterval = CMQC.MQWI_UNLIMITED

      messages = []
      try:
        while 1:
          msg = Q.get(None, msgDesc, getOpts)
          messages.append(msg)
          if not options.all==True and options.index==None and not options.lifo==True:
            break

          # null MsgId and CorrelId, or cursor won't move up
          # the Q
          msgDesc['MsgId'] = ''
          msgDesc['CorrelId'] = ''
      except MQMIError, me:
        #assume that error is raised when there are
        #no more messages in queue
        pass
      
      if options.lifo==True:
        messages.reverse()
      
      if not options.all==True and options.index==None:
        messages=messages[0:1]
      
      if not options.index==None:
        printMessage(options,messages[int(options.index)])
      else:
        for message in messages:
          printMessage(options,message)
        
    except MQException, err:
      print  '[ERROR]',err.errorCodes[err.msg]
      print usage % (sys.argv[0],)
      return err.code
    except MQMIError,err:
      if err.reason==2033:
        #no messages
        print 'No messages.' 
      else:
        print err
        return err.reason


def printMessage(options,message):
  if options.saveFile==True:
    seq=1
    if not options.fileName==None:
      fileName=options.fileName
    else:
      fileName='message'
      fileName='%s%05d' %(fileName,seq)
    while os.path.exists(fileName)==True:
      fileName=fileName[:-5]
      seq=seq+1
      fileName='%s%05d' %(fileName,seq)
    f=open(fileName,'w')
    f.write(message)
    f.close()
  else:
    if not options.noDelim==True:
      print '-'*70
    print message

def parseOptions():  
  parser = OptionParser(usage=(usage % ('%prog',)))
  parser.add_option("-f", 
                    "--file", 
                    action="store_true",
                    dest="saveFile",
                    help="Save message to a file with name 'message'.", )
  parser.add_option("-n", 
                    "--file-name", 
                    dest="fileName",
                    help="File name for message. Use with -f option.", )
  parser.add_option("-i", 
                    "--index", 
                    dest="index",
                    help="Browse message in the middle of queue.", )
  parser.add_option("-A", 
                    "--all", 
                    action="store_true",
                    dest="all",
                    help="Browse all messages. If messages are saved to file,"+
                     " messages have sequence number in the file name.", )
  parser.add_option("-d", 
                    "--depth", 
                    action="store_true",
                    dest="depth",
                    help="Print just the queue depth.", )
  parser.add_option("-l", 
                    "--lifo", 
                    action="store_true",
                    dest="lifo",
                    help="Print last message first (Last-In-First-Out).", )
  parser.add_option("", 
                    "--no-delim", 
                    action="store_true",
                    dest="noDelim",
                    help="Do not print message delimeter.", )
  
  (options, args) = parser.parse_args()
  return (options, args)

#MQException class that holds application specific error codes
#and error messages
class MQException(Exception):
  errorCodes={'1': 'QMGRNAME, QNAME or MESSAGE missing.',
              '2': 'Too many arguments.',
              '3': 'File does not exist.',
              '4': 'QMGRNAME or QNAME missing.',
              '5': 'Index error. Not so many messages in queue.',
              }
  code=0
  def __init__(self, code):
    self.code=code
    self.msg = str(code)
    
if __name__ == "__main__":
    sys.exit(main())

Usage: PyBrowse.py [options] QMGRNAME QNAME

Options:
  -h, --help            show this help message and exit
  -f, --file            Save message to a file with name 'message'.
  -n FILENAME, --file-name=FILENAME
                        File name for message. Use with -f option.
  -i INDEX, --index=INDEX
                        Browse message in the middle of queue.
  -A, --all             Browse all messages. If messages are saved to file,
                        messages have sequence number in the file name.
  -d, --depth           Print just the queue depth.
  -l, --lifo            Print last message first (Last-In-First-Out).
  --no-delim            Do not print message delimeter.

from distutils.core import setup
import py2exe

setup(
    console = ["PyPut.py"],
    )

setup(
    console = ["PyGet.py"],
    )

setup(
    console = ["PyBrowse.py"],
    )