A DHT crawler framework using asyncio.
from maga import Maga
import logging
logging.basicConfig(level=logging.INFO)
class Crawler(Maga):
async def handler(self, infohash, addr):
logging.info(addr)
logging.info(infohash)
# Or, if you want to have more control
class Crawler(Maga):
async def handle_get_peers(self, infohash, addr):
logging.info(
"Receive get peers message from DHT {}. Infohash: {}.".format(
addr, infohash
)
)
async def handle_announce_peer(self, infohash, addr, peer_addr):
logging.info(
"Receive announce peer message from DHT {}. Infohash: {}. Peer address:{}".format(
addr, infohash, peer_addr
)
)
crawler = Crawler()
# Set port to 0 will use a random available port
crawler.run(port=0)- Add peer_addr param to handle_announce_peer method.
- Don't raise NotImplementedError on handler
- Don't fail when signals are not implemented.( #3 )
- Add handle_get_peers, handle_announce_peer method.
- Add addr param to handler
React
Typescript
Django
Laravel
Facebook
Microsoft
Google
Alibaba
D3
Tencent