Как выполнить оператор вставки с использованием массивов в python 3 flask-restful - PullRequest
0 голосов
/ 12 декабря 2018

Я хочу сделать несколько входов JSON, используя список массивов.Приведенный ниже код показывает только одну запись.

parser = reqparse.RequestParser()
parser.add_argument('tblskuid', type = str)
parser.add_argument('tbluserid', type = str)
args = parser.parse_args()

tblskuid = args['tblskuid']
tbluserid = args['tbluserid']

tbl_bo = [
         (tblskuid, tbluserid, )
            ]

conn = psycopg2.connect(database='mobiletracker', user='', host='', password='')
cursor = conn.cursor()
args_str = ','.join(['%s'] * len(tbl_bo))
cursor.execute(cursor.mogrify('INSERT INTO tbl_bad_orders_product(tblskuid, tbluserid) VALUES {}'.format(args_str), tbl_bo).decode('utf8'))
conn.commit()
cursor.close()

Я хочу вставить список данных в массив, подобный этому.

tbl_bo = [
      {
        "tbl_skuid":"1",
        "tbluserid":"1",

      },
      {
        "tbl_skuid":"message",
        "tbluserid":"employeeid",

      }
    ] 

и как я должен выполнитьотправка ответа с использованием почтальона?любая помощь была бы очень признательна.Заранее спасибо.

1 Ответ

0 голосов
/ 21 декабря 2018

Я собираюсь ответить на свой вопрос, потому что я решил его сам.Мы собираемся использовать ответ json, используя функцию курсора.Я не хочу использовать sqlAlchemy из-за его сложности и проблем со скоростью при отправке больших объемов данных.Я думаю, что RequestParser () не является эффективным способом для нескольких записей с использованием массивов.Теперь вот код.

class Logs_api(Resource):
    @jwt_required
    def post(self):
        try: 
          conn = None
          #getting the json request of post data 
          json_dict = request.get_json(force=True, silent=True)

          #count the length of json dictionary
          x = len(json_dict)


          tbl_logs = []
          for i in chain(range(0, x)):

            tbl_logs.append((json_dict[i]['tbluserid'],json_dict[i]['event'],json_dict[i]['current_longitude'],json_dict[i]['current_latitude'],json_dict[i]['end_longitude'],json_dict[i]['end_latitude'],json_dict[i]['gps_accuracy'],json_dict[i]['gps_provider'],json_dict[i]['battery'],json_dict[i]['datetime_log'], ))

          conn = psycopg2.connect(database='yourdb', user='dbuser', host='dbhost', password='dbpass', options='-c statement_timeout=1000')  
          cursor = conn.cursor()
          args_str = ','.join(['%s'] * len(tbl_logs))
        #   print(cursor.mogrify('INSERT INTO tbl_location_logs(tbluserid, event, current_longitude, current_latitude, end_longitude, end_latitude, gps_accuracy, gps_provider, battery, datetime_log) VALUES {}'.format(args_str), tbl_logs).decode('utf8'))
          cursor.execute(cursor.mogrify('INSERT INTO tbl_location_logs(tbluserid, event, current_longitude, current_latitude, end_longitude, end_latitude, gps_accuracy, gps_provider, battery, datetime_log) VALUES {}'.format(args_str), tbl_logs).decode('utf8'))
          conn.commit()
          cursor.close()

          return {'status' : 'success', 'message' : 'success'}
        except Exception as e:
            x = str(e)
            x.replace('\n', '')

            return {'status' : 'failed', 'message' : str(x)}
        finally:
            if conn is not None:
                conn.close()

в почтальоне, используйте raw, а не x-www-form-urlencoded и введите свой json там.Это мой пример формата.

[ 
  {
        "tbluserid": "2",
        "event": "sample",
        "current_longitude": "20",
        "current_latitude": "200",
        "end_longitude": "20",
        "end_latitude": "200",
        "gps_accuracy": "200",
        "gps_provider": "google maps pangett",
        "battery": "200",
        "datetime_log": "2018-02-02 23:00:00"
    }
]

с помощью приведенной выше структуры кода, я разместил в общей сложности 5800+ данных всего за 1,2 секунды, и доказательством являются 2 изображения ниже:

enter image description here

enter image description here

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...