asterisk.ru

Код: Выделить всё

[queue_2]
ringinuse=no
timeout=6
retry=10
strategy=rrmemory
member => SIP/1000,0
....
member => SIP/1034,1

Код: Выделить всё

#!/usr/local/bin/python2.7
# coding: utf-8
import asterisk.manager
import sys
import time
from datetime import datetime, timedelta
from apscheduler.schedulers.background import BackgroundScheduler
from apscheduler.triggers.date import DateTrigger
host='127.0.0.1'
login = 'usr'
password = 'pswd'
pausedlist=list()
sched = BackgroundScheduler()
sched.start()

class MyManager(asterisk.manager.Manager):

    def unpause(self, peer, state):
        """ pauses in queue """
        cdict = {'Action': 'QueuePause'}
        cdict['Interface'] = peer
        cdict['Paused'] = state
        cdict['Reason'] = 'Hold '+str(state)
        response = self.send_action(cdict)
        return response



def handle_devstate(event, manager):
    print event.headers
    if event.headers[u'PeerStatus'] in[ u'Unregistered',u'Unreachable']:
        sippeer=event.headers[u'Peer'].split(u'/')[1]
        manager.command(u"devstate change Custom:DND"+ sippeer+ u" UNAVAILABLE")

def unpausehandler(peer, manager):
    manager.unpause(peer,False)
    pausedlist.remove(peer)
    print peer

def handle_status(event, manager):
    if event.headers[u'PausedReason']==u'Auto-Pause':
        if event.headers[u'Interface'] not in pausedlist:
            pausedlist.append(event.headers[u'Interface'])
            run_date =DateTrigger( datetime.now() + timedelta(seconds=300))
            sched.add_job(unpausehandler,args=[event.headers[u'Interface'],manager],trigger=run_date)


def handle_event(event, manager):
  print "Received event: %s" % event.name

manager = MyManager()
try:
   try:
      manager.connect(host)
      manager.login(login, password)

      manager.register_event('QueueMemberPause', handle_status) # shutdown
      manager.register_event('PeerStatus', handle_devstate)

      response = manager.status()
      while True:
	  time.sleep(10)
      pass

      manager.logoff()
   except asterisk.manager.ManagerSocketException as e:
      print "Error connecting to the manager: %s" % e.strerror
      sys.exit(1)
   except asterisk.manager.ManagerAuthException as e:
      print "Error logging in to the manager: %s" % e.strerror
      sys.exit(1)
   except asterisk.manager.ManagerException as e:
      print "Error: %s" % e.strerror
      sys.exit(1)

finally:
    manager.close()