arq_python

import psycopg2
import io
import json

from psycopg2.extras import Json
from psycopg2.extensions import register_adapter

try:
    connection = psycopg2.connect(user = "parking",password = "pg2019",host = "172.17.0.2",port = "5432",database = "parkingdb")

    cursor = connection.cursor()

    gravar = []
    with open('/dados_json2/arq.json') as f:
        for line in f:
            gravar.append(json.loads(line))

    for item in gravar:
        #my_data = item
        my_data = json.dumps(item)
        cursor.execute("INSERT INTO parking VALUES (%s)", (my_data, ))


    connection.commit()

    print("Ok, sucesso !")

except (Exception, psycopg2.Error) as error :
    print ("Error while connecting to PostgreSQL", error)
finally:
    #closing database connection.
        if(connection):
            cursor.close()
            connection.close()
            print("PostgreSQL connection is closed")