如何从 config.json 文件访问信息到 python 文件？

Question

问题是我无法从 config.json 文件访问我的 python 文件中的信息 我在下面提供了 JSON 数据和 python 代码 我已经尝试了请求模块中的所有内容 但是我可以在没有配置文件的情况下访问响应但是， 我需要配置文件 下面是一个json文件

{
    "api_data": {
        "request_url": "https://newapi.zivame.com/api/v1/catalog/list",
        "post_data" : {"category_ids" : "948",
                        "limit" : "10000"},
        "my_headers":{"Content-Type": "application/json"}
    },
    "redshift":{
        "host":"XXX.XXXX.XXX",
        "user":"XXXX",
        "password":"XXXXXXXX",
        "port": 8080,
        "db":"XXXX"
    },
    "s3":{
        "access_key":"XXXXXXXXX",
        "secret_key":"XXXXXXXXXX",
        "region":"XX-XXXXX-1",
        "path":"XXXXXXXXXXXX/XXX",
        "table":"XXXXXX",
        "bucket":"XXXX",
        "file": "XXXXXX",
        "copy_column": "XXX",
        "local_path": "XXXXX"
    },
    "csv_file": {
        "promo_zivame": ""
    }
}

这就是程序

#!/usr/bin/python                                                                                                                                                                 
import json                                                                                                                                                                       
import psycopg2                                                                                                                                                                   
import requests                                                                                                                                                                   
import os

BASE_PATH = os.path.dirname(os.path.realpath(__file__))

with open(BASE_PATH+'/config.json') as json_data_file:                                                                                                                            
    data = json.load(json_data_file)

#api_config = data['api_data']                                                                                                                                                    
#redshift = data['redshift']                                                                                                                                                      
s3_config = data['s3']

#x = print(api_config.get('request_url'))

class ApiResponse:                                                                                                                                                                
    #api response                                                                                                                                                                 
    def api_data(self, api_config):                                                                                                                                               
        print("starting api_data")                                                                                                                                                
        try:                                                                                                                                                                      
            self.ApiResponse = requests.post(api_config['request_url'], api_config['post_data'], api_config['my_headers'])                                                        
            data_1 = self.ApiResponse                                                                                                                                             
            #data = json.dump(self.ApiResponse)                                                                                                                                   
            print("API Result Response")                                                                                                                                          
            print(())                                                                                                                                                             
            print(self.ApiResponse)                                                                                                                                               
            return (self.ApiResponse)

        except Exception:                                                                                                                                                         
            print("response not found")                                                                                                                                           
            return False

    def redshift_connect(self, redshift):                                                                                                                                         
        try:                                                                                                                                                                      
            # Amazon Redshift connect string                                                                                                                                      
            self.con = psycopg2.connect(                                                                                                                                          
                host=redshift['host'],                                                                                                                                            
                user=redshift['user'],                                                                                                                                            
                port=redshift['port'],                                                                                                                                            
                password=redshift['password'],                                                                                                                                    
                dbname=redshift['db'])                                                                                                                                            
            print(self.con)                                                                                                                                                       
            return self.con                                                                                                                                                       
        except Exception:                                                                                                                                                         
            print("Error in Redshift connection")                                                                                                                                 
            return False                                                                                                                                                          
def main():                                                                                                                                                                       
    c1 = ApiResponse()                                                                                                                                                                   
    api_config = data['api_data']                                                                                                                                                 
    redshift = data['redshift']                                                                                                                                                   
    c1.api_data(api_config)                                                                                                                                                       
    c1.api_data(data)                                                                                                                                                             
    c1.redshift_connect(redshift)

if __name__=='__main__':                                                                                                                                                          
    main()

Answer 1

requests.post() 的第三个参数是 json。要提供headers，您需要按照@JustinEzequiel 的建议明确使用参数的名称。在此处查看请求文档：2.python-requests.org/en/v1.1.0/user/quickstart/#custom-headers

requests.post(api_config['request_url'], json=api_config['post_data'], headers=api_config['my_headers'])

Answer 2

从https://stackoverflow.com/a/16696317/5386938借代码

import requests

api_config = {
    "request_url": "https://newapi.zivame.com/api/v1/catalog/list",
    "post_data" : {"category_ids" : "948", "limit" : "10000"},
    "my_headers":{"Content-Type": "application/json"}
    }
local_filename = 'the_response.json'
with requests.post(api_config['request_url'], json=api_config['post_data'], headers=api_config['my_headers'], stream=True) as r:
    r.raise_for_status()
    with open(local_filename, 'wb') as f:
        for chunk in r.iter_content(chunk_size=8192): 
            if chunk: # filter out keep-alive new chunks
                f.write(chunk)

将响应保存到文件 ('the_response.json') 中，然后您可以传递。注意stream=True 传递给requests.post