如何在 if else 语句中比较 request.get 结果

Question

我正在制作一个新脚本，它将作为以太坊私钥的输入列表并生成带有余额的相应地址，如果发现余额以及私钥和地址，则将余额保存在文件中。

现在，我几乎可以肯定我的问题出在条件范围内，但无法弄清楚。

脚本步骤： 1. 将私钥文件作为输入（-i 标志） 2.将它们转换为公共地址/解码它们 3. 触发对 Etherscan 的 API 调用以获取有关地址的信息 4.如果API调用中json()["result"] > 0，则将其写入输出文件（-o标志），否则打印输出并休眠1秒

谁能指出我在哪里犯了错误？

我的代码：

#!/usr/bin/python
import sys, os, argparse, requests, ethereum, binascii, time
from multiprocessing import Pool

def scanether(balance):
    try:
        # Convert private key to address and print the result
        eth_address = ethereum.utils.privtoaddr(INPUTFILE)
        eth_address_hex = binascii.hexlify(eth_address).decode("utf-8")
        eth_balance = requests.get("https://api.etherscan.io/api?module=account&action=balance&address=0x" + eth_address_hex + "&tag=latest&apikey=APIKEYHERE").json()["result"]

        # Check if the result is > 0
        if ('result' != 0) in r.eth_balance: 
            print("[*] Address with balance found: " + eth_address_hex + priv)
            # Write match to OUTPUTFILE
            fHandle = open(OUTPUTFILE,'a')
            fHandle.write(eth_address_hex + privkey + "\n")
            fHandle.close()
        else:
            print("balance: {} address: 0x{} privkey: {}".format(float(eth_balance)/100000000, eth_address_hex, priv))
            time.sleep(1)


    except Exception as e:
        return

if __name__ == '__main__':
    print("""
# Finding the Ethereum address with balance
        """)
    # Parse arguments
    parser = argparse.ArgumentParser()
    parser.add_argument('-i', '--inputfile', default='input.txt', help='input file')
    parser.add_argument('-o', '--outputfile', default='output.txt', help='output file')
    parser.add_argument('-t', '--threads', default=200, help='threads')
    args = parser.parse_args()

    INPUTFILE=args.inputfile
    OUTPUTFILE=args.outputfile
    MAXPROCESSES=int(args.threads)

    try:
        addresses = open(INPUTFILE, "r").readlines()
    except FileNotFoundError as e:
        print(e)
        exit(e.errno)

    print("Scan in progress...")
    pool = Pool(processes=MAXPROCESSES)
    pool.map(scanether, addresses)
    print("Scan finished.")

输出如下：

Answer 1

问题是你使用了一些不在函数范围内的变量：

def scanether(balance):
    try:
        # Convert private key to address and print the result
        eth_address = ethereum.utils.privtoaddr(INPUTFILE)
        ...

        # Check if the result is > 0
        if ('result' != 0) in r.eth_balance: 
            print("[*] Address with balance found: " + eth_address_hex + priv)
            # Write match to OUTPUTFILE
            fHandle = open(OUTPUTFILE,'a')
            ...

    except Exception as e:
        return

这里INPUTFILE 和OUTPUTFILE 不在范围内，它会引发一个异常被捕获然后函数简单地返回......

您需要将它们作为参数传递：

def scanether(balance, INPUTFILE, OUTPUTFILE):
    ...


...

    print("Scan in progress...")
    pool = Pool(processes=MAXPROCESSES)
    def scanether_wrapper(address, ifile=INPUTFILE, ofile=OUTPUTFILE):
        return scanether(address, ifile, ofile)
    pool.map(scanether_wrapper, addresses)
    print("Scan finished.")

Answer 2

您可以使用以下代码作为参考。在处理响应之前，您应该确定您提出的请求是否成功。

请参阅以下代码以供进一步参考。

import requests
url  = "https://******.com"
r = requests.get(url)
print(r.status_code)

在使用响应之前，请始终检查状态码是否为 200。

谢谢！