external/fastocloud_admin
1
0
Fork 0
mirror of https://github.com/fastogt/fastocloud_admin.git synced 2025-03-09 23:38:52 +00:00
Code Issues Releases Wiki Activity

Review

Browse source
This commit is contained in:
topilski 2019-09-19 15:19:36 -04:00
parent 422f603130
commit 2165b3b8d4
1 changed files with 14 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

17
scripts/import_subscribers_from_xtream.py
View file

@ -15,7 +15,7 @@ if __name__ == '__main__':
parser = argparse.ArgumentParser(prog=PROJECT_NAME, usage='%(prog)s [options]') parser = argparse.ArgumentParser(prog=PROJECT_NAME, usage='%(prog)s [options]')
parser.add_argument('--mongo_uri', help='MongoDB credentials', default='mongodb://localhost:27017/iptv') parser.add_argument('--mongo_uri', help='MongoDB credentials', default='mongodb://localhost:27017/iptv')
parser.add_argument('--mysql_host', help='MySQL host', default='localhost') parser.add_argument('--mysql_host', help='MySQL host', default='localhost')
parser.add_argument('--mysql_user', help='MySQL password', default='') parser.add_argument('--mysql_user', help='MySQL username', default='')
parser.add_argument('--mysql_password', help='MySQL password', default='') parser.add_argument('--mysql_password', help='MySQL password', default='')
argv = parser.parse_args() argv = parser.parse_args()
@ -30,9 +30,20 @@ if __name__ == '__main__':
mydb = mysql.connector.connect( mydb = mysql.connector.connect(
host=mysql_host, host=mysql_host,
user=mysql_user, user=mysql_user,
passwd=mysql_user passwd=mysql_password,
database=''
) )
for sql_entry in table: mycursor = mydb.cursor()
sql = 'SELECT username,passwords FROM users'
mycursor.execute(sql)
myresult = mycursor.fetchall()
for sql_entry in myresult:
new_user = SubscriberUser.make_subscriber(email=sql_entry.username, password=sql_entry.password, country='US') new_user = SubscriberUser.make_subscriber(email=sql_entry.username, password=sql_entry.password, country='US')
new_user.save() new_user.save()
mydb.close()