tasks.py 文件源码

def notify_user(self, tx_pk):
    t = Transaction.objects.get(pk=tx_pk)

    data = {
        'address': t.to_address,
        'amount': t.value,
        'tx_hash': t.hash
    }

    try:
        requests.post(t.owner.web_hook, data=data)
        t.notification_status = constants.NOTIFICATION_DONE
        t.save()

    except (ConnectionError, ConnectTimeout) as e:
        raise self.retry(countdown=constants.NOTIFY_RETRY_COUNTDOWN)