import re import pymysql

db = pymysql.connect(«10.1.6.171»,«ldap»,«123456»,«asterisk» ) cursor = db.cursor()

from ldap3 import Server, Connection, SASL, DIGEST_MD5,SUBTREE

server = Server(host = '10.1.6.180', port = 389) conn = Connection(server, autobind = True, version = 3, clientstrategy = 'SYNC', authentication = SASL,

                       sasl_mechanism = DIGEST_MD5, sasl_credentials = (None, 'admin', 'Z12345xcvb', None))

#print('test')

userdn = «cn=admin,ou=users,ou=data,ou=prod,ou=authserver,dc=asterisk,dc=AAA» basedn = «dc=asterisk,dc=AAA» filter = «uid=admin» totalentries = 0 conn.search(searchbase = 'dc=asterisk,dc=AAA',

       ##search_filter = '(objectClass=inetOrgPerson)',
       search_filter = '(objectCategory=Person)',            
       search_scope = SUBTREE,
       attributes = ['title','homePhone'],
       paged_size = 1000)

totalentries += len(conn.response) #result = conn.search(searchbase=basedn, searchfilter=filter, search_scope=SUBTREE)

try:

  for entry in conn.response:

      str1 = entry['attributes']
      cont=(str1.get('title'))
      phone=(str1.get('homePhone'))
      if cont != [] and phone != [] : 
          ##print('ok')
          print(f"{cont} {phone}")
          ins=f"insert into sip(name,host,type,secret,qualify,context) values('{phone}','dynamic','friend','123456','yes','{cont}');"
          #ins =f"{phone} dsdsds {title}")
          print(ins)
          
          try:
              cursor.execute(ins)
          except:
              print('уже в базе')
      
          ##ins=f"insert into tab(p1,p2,p3,p4,p5) values('{str(mass[0])[9:18]}','{extdb}','{caldb}','{td}','{acode}');"
       
     
     

except:

  print("govno")

 
      ##print("ERR")

conn.unbind()