Описание тега asyncpg

Вопросы с тегом
NoneAsyncpg - это асинхронная клиентская библиотека PostgrSQL для Python.
1 ответ

Как добавить параметр коллекции (список и т. Д.) В курсор подготовленного оператора

Поэтому я использую подготовленное заявление asyncpg и выполняю запрос. Я передаю позиционные аргументы в моем запросе. В настоящее время я прохожу stmt.cursor(params[0], params[1]) но что, если я не знаю, сколько аргументов передается, поэтому хоте…
13 янв '18 в 01:40
1 ответ

Как использовать подготовленные отчеты для вставок с asyncpg?

Пакет документов https://magicstack.github.io/asyncpg/current/api/index.html. Кажется, единственные сопрограммы имеют дело с запросами SELECT с подготовленными утверждениями. Список документов cursor, explain, fetch, fetchrow, fetchval, Не кажется о…
16 дек '18 в 06:23
0 ответов

Должен ли я закрывать соединение после каждой партии вставки?

Мне нужно вставлять пару десятков строк удаленно каждые 10 секунд. Я не уверен, должен ли я использовать async with connection вокруг каждой вставки, закрывая соединение и открывая каждые 10 секунд, или просто await conn = ... один раз и держи ручку…
15 дек '18 в 15:17
1 ответ

Сертификат Подтвердить Сбой Postgresql Heroku

Я использую базу данных PostgreSQL через Heroku и asyncpg. Мой URL-адрес: postgres://user:pass@ec2-23-21-76-49.compute-1.amazonaws.com:5432/db_name, Когда я запускаю это, я получаю ошибку: ssl.SSLError: [SSL: CERTIFICATE_VERIFY_FAILED] certificate v…
29 дек '17 в 07:14
0 ответов

Python асинхронный HTTP-запрос

У меня есть оборудование с интерфейсом http, которое часто генерирует бесконечную страницу http со значениями, которые я хочу проанализировать и сохранить в базе данных. Я начал с запросов: import asyncio import asyncpg import requests class node_ht…
08 май '18 в 16:26
2 ответа

Лучший способ вставить несколько строк с помощью asyncpg

Я хочу вставить несколько строк и получить идентификаторы обратно с помощью asyncpg, я нашел два способа: 1: создать sql, как это INSERT INTO films (code, title, did, date_prod, kind) VALUES ('B6717', 'Tampopo', 110, '1985-02-10', 'Comedy'), ('HG120…
02 май '17 в 13:27
2 ответа

Как вернуть первичный ключ вновь вставленной строки, используя asyncpg?

Я хотел сделать что-то вроде этого: async with app.pg_pool.acquire() as pg: uid = await pg.execute('INSERT INTO users (created, keyed, key, email) ' 'VALUES ($1, $2, $3, $4) RETURNING id', time, time, key, rj['email'])['id'] тем не мение Connection.…
05 ноя '17 в 21:56
1 ответ

Ошибка сохранения часового пояса в Postgresql

Пытаясь сохранить дату в PostgreSQL, используя Python, он дает мне UTC + 2 для моего часового пояса, в то время как это UTC + 1 (не обращайте внимания на разницу, я просто использовал тест Python, чтобы узнать, каков часовой пояс) In [8]: datetime.d…
07 июл '18 в 14:35
1 ответ

Как использовать asyncpg.copy_to_table с Pandas Dataframe

Я пытаюсь написать большой файл данных Pandas для postgres с помощью asyncpg, но получаю ошибки при попытке сделать это с помощью функции copy_to_table. У меня есть рабочий код с использованием psycopg2.copy_from с использованием StringIO, но он не …
16 фев '19 в 14:24
1 ответ

asyncpg получить отзыв (python)

Я использую psycopg2 для управления элементами в моей базе данных PostgreSQL. Недавно кто-то предложил мне улучшить транзакции с моей базой данных, используя asyncio и asyncpg в моем коде. Я осмотрел Stack Overflow и прочитал документацию для пример…
05 ноя '18 в 17:23
1 ответ

Python3 SyntaxError с asyncpg

Я пытаюсь создать пул соединений, как показано в документации для тестирования модуля. Вот моя последняя попытка: import asyncpg cs = "user:password@my_postgresql_server_ipaddr:port/database?name=db_name" async with asyncpg.create_pool(dsn=cs) as po…
13 июл '18 в 09:48
0 ответов

Как реализовать asyncpg транзакции декоратор?

Я попытался реализовать оболочку транзакции asyncpg, как показано ниже: def asyncpg_tx(autocommit=True, ignore_err=False): ''' :param autocommit: :param ignore_err: :return: ''' async def decorator(func): try: @functools.wraps(func) async def func_e…
23 апр '18 в 14:50
1 ответ

Лучший способ открыть / закрыть соединение с БД с помощью async/await

В обучающих программах, которые я обнаружил, всегда открываются и закрываются соединения для каждого запроса, например: import asyncio import asyncpg async def run(): conn = await asyncpg.connect(user='user', password='password', database='database'…
02 июн '18 в 12:30
1 ответ

Asyncpg пул случайно перестает отвечать

Я использую asyncpg Pool для моего бота discord.py, но, как я уже сказал в заголовке, он случайно перестает отвечать. Команды, использующие пул, не работают, но другие работают, и я уверен, что закрываю все соединения после их использования. Я пытал…
30 июл '18 в 11:06
2 ответа

Синтаксическая ошибка UPSERT связана с UPDATE в PostgreSQL (python)

Я все еще изучаю PostgreSQL. Во время моего тестирования я использовал оператор INSERT только в psycopg2 и теперь asyncpg. Теперь у меня есть необходимость ОБНОВИТЬ данные в моей тестовой базе данных, а не заменять их все. В настоящее время я пытаюс…
09 ноя '18 в 16:36
1 ответ

Как исправить "синтаксическую ошибку на уровне или около $1" с помощью asyncpg API

Я пытаюсь вставить значение в таблицу базы данных postgresql, используя аргументы запроса через asyncpg API. Я создал свою таблицу следующим образом: CREATE TABLE my_table ( cat BIGINT, roles BIGINT ARRAY ); Я уже пытался напрямую привести аргумент …
27 янв '19 в 04:16
1 ответ

asyncio + asyncpg + pandas: получить pandas.df с асинхронным выбором из db - ОШИБКА

Отредактировал мой код - СЕЙЧАС он работает. Я пытаюсь получить некоторую дату из моей базы данных Postgres через пул соединений asyncpg асинхронно. В основном моя база данных содержит около 100 различных таблиц (на город), и я пытаюсь собрать все д…
08 фев '19 в 13:52
0 ответов

Почему я получаю сообщение об ошибке при попытке получить строку из базы данных в Python?

Мне нужно получить строку из базы данных с необходимым параметром. Я использую asycpg для работы с Postgresql. Вот мой код для этого: row = await connection.fetchrow('SELECT * FROM ' + self.game_name +' WHERE full_url = $1', full_url) Когда я запуск…
10 окт '18 в 20:02
1 ответ

Asyncpg и AWS Lambda

Я пытаюсь использовать asyncpg с AWS Lambda и получил следующую ошибку при попытке import asyncpg Unable to import module 'handler': No module named asyncpg.protocol.protocol' Я импортирую зависимости Python, как в этом ответе с и без виртуальной ср…
02 июн '17 в 14:37
1 ответ

Использование asyncpg пула соединений с Sanic

Я почистил несколько примеров в Интернете и придумал это. Этот код работает, но мне интересно, есть ли лучший способ сделать это? user.py: from asyncpg import create_pool from sanic import Blueprint bp = Blueprint('dp') class pg: def __init__(self, …
23 апр '18 в 10:11