
Security News
Crates.io Users Targeted by Phishing Emails
The Rust Security Response WG is warning of phishing emails from rustfoundation.dev targeting crates.io users.
VirtualEnv QuickStart
$ virtualenv bn
$ . ./bn/bin/activate
(bn) $ pip3 install --upgrade pip
(bn) $ pip3 install blocknative-sdk
(bn) $ curl 'https://raw.githubusercontent.com/blocknative/python-sdk/main/examples/subscribe.py' > subscribe.py
(bn) $ python3 subscribe.py myapikey.key
Manual Install
python3 setup.py install
To get started using the Blocknative Python SDK you must first obtain an API Key. You can do so by heading over to Blocknative.com!
from blocknative.stream import Stream
import json
# Initialize the stream
stream = Stream('<API_KEY>')
# Define your transaction handler which has the context of a specific subscription.
async def txn_handler(txn, unsubscribe):
# Output the transaction data to the console
print(json.dumps(txn, indent=4))
# Define the address you want to watch
uniswap_v2_address = '0x7a250d5630b4cf539739df2c5dacb4c659f2488d'
# Register the subscription
stream.subscribe_address(uniswap_v2_address, txn_handler)
# Start the websocket connection and start receiving events!
stream.connect()
from blocknative.stream import Stream
import json
# Initialize the stream
stream = Stream('<API_KEY>')
# Define your transaction handler
async def txn_handler(txn, unsubscribe):
if txn['status'] == "confirmed":
# Output the transaction data to the console
print(json.dumps(txn, indent=4))
# Unsubscribe from this subscription
unsubscribe()
# Define the address you want to watch
uniswap_v2_address = '0x7a250d5630b4cf539739df2c5dacb4c659f2488d'
# Register the subscription
stream.subscribe_address(uniswap_v2_address, txn_handler)
# Start the websocket connection and start receiving events!
stream.connect()
from blocknative.stream import Stream
import json
stream = Stream('<API_KEY>')
async def txn_handler(txn, unsubscribe):
# This will only get called with transactions that have status of 'confirmed'
# This is due to the global filter above
print(json.dumps(txn, indent=4))
uniswap_v2_address = '0x7a250d5630b4cf539739df2c5dacb4c659f2488d'
filters = [{
'status': 'confirmed'
}]
# Global filter will apply to all of these subscriptions
stream.subscribe_address(curve_fi_address, txn_handler, filter=filters)
# Start the websocket connection and start receiving events!
stream.connect()
Similar as above but this time we use global filters which will apply to all subscriptions.
from blocknative.stream import Stream
import json
global_filters = [{
'status': 'confirmed'
}]
stream = Stream('<API_KEY>', global_filters=global_filters)
async def txn_handler(txn, unsubscribe):
# This will only get called with transactions that have status of 'confirmed'
# This is due to the global filter above
print(json.dumps(txn, indent=4))
uniswap_v2_address = '0x7a250d5630b4cf539739df2c5dacb4c659f2488d'
curve_fi_address = '0xdf5e0e81dff6faf3a7e52ba697820c5e32d806a8'
sushi_swap_address = '0xd9e1ce17f2641f24ae83637ab66a2cca9c378b9f'
# Global filter will apply to all of these subscriptions
stream.subscribe_address(curve_fi_address, txn_handler)
stream.subscribe_address(uniswap_v2_address, txn_handler)
stream.subscribe_address(sushi_swap_address, txn_handler)
# Start the websocket connection and start receiving events!
stream.connect()
from blocknative.stream import Stream
import json
BSC_NETWORK_ID = 56
# Initialize the stream - specify network_id `56` to connect to bsc main
stream = Stream('<API_KEY>', network_id=BSC_NETWORK_ID)
# Define your transaction handler which has the context of a specific subscription.
async def txn_handler(txn, unsubscribe):
# Output the transaction data to the console
print(json.dumps(txn, indent=4))
# Define the address you want to watch
pancakeswap_v2_address = '0x10ed43c718714eb63d5aa57b78b54704e256024e'
# Register the subscription
stream.subscribe_address(pancakeswap_v2_address, txn_handler)
# Start the websocket connection and start receiving events!
stream.connect()
FAQs
Blocknative's Python SDK.
We found that blocknative-sdk demonstrated a healthy version release cadence and project activity because the last version was released less than a year ago. It has 1 open source maintainer collaborating on the project.
Did you know?
Socket for GitHub automatically highlights issues in each pull request and monitors the health of all your open source dependencies. Discover the contents of your packages and block harmful activity before you install or update your dependencies.
Security News
The Rust Security Response WG is warning of phishing emails from rustfoundation.dev targeting crates.io users.
Product
Socket now lets you customize pull request alert headers, helping security teams share clear guidance right in PRs to speed reviews and reduce back-and-forth.
Product
Socket's Rust support is moving to Beta: all users can scan Cargo projects and generate SBOMs, including Cargo.toml-only crates, with Rust-aware supply chain checks.