Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- import urllib3
- import json
- import certifi
- import psycopg2
- from psycopg2.extras import Json
- http = urllib3.PoolManager(
- cert_reqs='CERT_REQUIRED',
- ca_certs=certifi.where())
- url = '<API-URL>'
- headers = urllib3.util.make_headers(basic_auth='<user>:<passowrd>')
- r = http.request('GET', url, headers=headers)
- data = json.loads(r.data.decode('utf-8'))
- def insert_into_table(data):
- for item in data:
- item['id'] = Json(item['id'])
- with psycopg2.connect(database='test3', user='<username>', password='<password>', host='localhost') as conn:
- with conn.cursor() as cursor:
- query = """
- INSERT into
- Countries
- (revenue)
- VALUES
- (%(id)s);
- """
- cursor.executemany(query, data)
- conn.commit()
- insert_into_table(data)
- {
- "expand": "<>",
- "startAt": 0,
- "maxResults": 50,
- "total": 13372,
- "issues": [
- {
- "expand": "<>",
- "id": "41508",
- "self": "<>",
- "key": "<>",
- "fields": {
- "issuetype": {
- "self": "<>",
- "id": "1",
- "description": "<>",
- "iconUrl": "<>",
- "name": "<>",
- "subtask": <>,
- "avatarId": <>
- },
Add Comment
Please, Sign In to add comment