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()