I am trying to insert bitcoin transactions into MongoDB using python3. Below is my code :

import pymongo
import sys
import json
import time
from bitcoinrpc.authproxy import AuthServiceProxy, JSONRPCException

rpc_connection = AuthServiceProxy("http://xxx:xxx@ipaddress:port")

def getTransaction():
    addresses = []
    txa = []
    commands = [ [ "getblockhash", height] for height in range(400000,550000) ]

    block_hashes = rpc_connection.batch_(commands)
    blocks = rpc_connection.batch_([ [ "getblock", h ] for h in block_hashes ])
    for txpre in blocks:
        for txs in txpre["tx"]:
    trans = conTransaction(txa)
    return trans

I am getting following error :

Traceback (most recent call last):
  File "/usr/lib/python3.6/threading.py", line 916, in _bootstrap_inner
  File "/usr/lib/python3.6/threading.py", line 864, in run
    self._target(*self._args, **self._kwargs)
  File "Test06.py", line 252, in getBTCTransaction
    block_hashes = rpc_connection.batch_(commands)
  File "/home/administrator/.local/lib/python3.6/site-packages/bitcoinrpc/authproxy.py", line 165, in batch_
    'Content-type': 'application/json'})
  File "/usr/lib/python3.6/http/client.py", line 1239, in request
    self._send_request(method, url, body, headers, encode_chunked)
  File "/usr/lib/python3.6/http/client.py", line 1285, in _send_request
    self.endheaders(body, encode_chunked=encode_chunked)
  File "/usr/lib/python3.6/http/client.py", line 1234, in endheaders
    self._send_output(message_body, encode_chunked=encode_chunked)
  File "/usr/lib/python3.6/http/client.py", line 1065, in _send_output
  File "/usr/lib/python3.6/http/client.py", line 986, in send
BrokenPipeError: [Errno 32] Broken pipe

I checked bitcoind rpc connection,its connected.
block_hashes = rpc_connection.batch_(commands) this code line is giving error. Can somebody tell me what's wrong? Working on a remote server.

  • did you obfuscate "xxx:xxx@ipaddress:port" for this question or do you have it like this in your code? in that case it would be clear why can't connect to it. Did you also check bitcoind to have the http-rpc interface open? – Rene Pickhardt Dec 18 '18 at 11:14
  • No, I have my IP address, port, user password in my code. I obfuscate it just for this question. Can you pleasse tell me how to check bitcoind to have the http-rpc interface open? I am new to bitcoind – Varsha Khandre Dec 18 '18 at 11:19
  • try wget http://xxx:xxx@ipaddress:port or curl you could even check with a networking tool if you really have a port open. also check your bitcoin.conf (c.f.: en.bitcoin.it/wiki/Running_Bitcoin you need to uncomment the lines for the RPC) – Rene Pickhardt Dec 18 '18 at 11:21
  • I tried this "wget xxx:xxx@ipaddress:port". Its giving response 200 OK. – Varsha Khandre Dec 18 '18 at 11:24
  • Given list rpc lines are uncommented and changed. Please check. server=1 rpcuser=xxx rpcpassword=xxx rpcclienttimeout=60 rpcallowip=remote_ipaddress_on_which_working/port rpcport=port rpcconnect=remote_ipaddress_on_which_working – Varsha Khandre Dec 18 '18 at 12:44

I found the solution. After doing changes in bitcoin config file, I just reduce the range of records to be inserted. RPC server cannot handle loads of data at one time. Otherwise, server down problem occurs and connection failed. Max 100 records get inserted at a time or less than that. And one more thing, keep restarting bitcoind RPC server by stop and start commands given below:

sudo killall bitcoind
bitcoind -daemon -rpcuser=xxx -rpcpassword=xxx -txindex -rpcallowip=youripaddress

Your Answer

By clicking "Post Your Answer", you acknowledge that you have read our updated terms of service, privacy policy and cookie policy, and that your continued use of the website is subject to these policies.

Not the answer you're looking for? Browse other questions tagged or ask your own question.