Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/MagicStack/asyncpg
/ functions
Functions
868 in github.com/MagicStack/asyncpg
⨍
Functions
868
◇
Types & classes
397
↳
Endpoints
6
Method
async_notice_callb
(con, message)
tests/test_listeners.py:136
Method
bad_connect
(*args, **kwargs)
tests/test_pool.py:187
Method
build_module
(self, module, module_file, package)
setup.py:102
Method
call_con_method
(self: Any, *args: Any, **kwargs: Any)
asyncpg/pool.py:61
Function
can_be_used
(connection)
asyncpg/connect_utils.py:1157
Method
check
()
tests/test_connect.py:1667
Method
check_simple
()
tests/test_prepare.py:437
Method
close
(self)
asyncpg/pool.py:264
Method
close_cb
(con)
tests/test_listeners.py:325
Method
connect_primary
(cls, **kwargs)
asyncpg/_testbase/__init__.py:533
Method
connect_standby
(cls, **kwargs)
asyncpg/_testbase/__init__.py:538
Method
connection_lost
(self, exc: typing.Optional[Exception])
asyncpg/connect_utils.py:944
Method
connection_lost
(self, exc)
asyncpg/connect_utils.py:1264
Method
copy_from_query
Copy the results of a query to a file or file-like object. :param str query: The query to copy the results of. :param ar
asyncpg/connection.py:878
Method
copy_from_table
Copy table contents to a file or file-like object. :param str table_name: The name of the table to copy data from. :para
asyncpg/connection.py:806
Method
copy_records_to_table
Copy a list of records to the specified table using binary COPY. :param str table_name: The name of the table to copy data to.
asyncpg/connection.py:1028
Method
copy_to_table
Copy data to the specified table. :param str table_name: The name of the table to copy data to. :param source:
asyncpg/connection.py:940
Function
create_pool
r"""Create a connection pool. Can be used either with an ``async with`` block: .. code-block:: python async with asyncpg.create_poo
asyncpg/pool.py:1075
Method
create_pool
(self, pool_class=pg_pool.Pool, connection_class=pg_connection.Connection, **kwargs)
asyncpg/_testbase/__init__.py:374
Method
cursor
Return a *cursor factory* for the prepared statement. :param args: Query arguments. :param int prefetch: The number of rows the *curs
asyncpg/prepared_stmt.py:104
Method
data_received
(self, data: bytes)
asyncpg/connect_utils.py:926
Method
destroy
(self)
asyncpg/cluster.py:721
Method
executemany
Execute an SQL *command* for each sequence of arguments in *args*. Example: .. code-block:: pycon >>> await con.execute
asyncpg/connection.py:366
Method
executemany
Execute the statement for each sequence of arguments in *args*. :param args: An iterable containing sequences of arguments. :param fl
asyncpg/prepared_stmt.py:236
Method
fetch
r"""Execute the statement and return a list of :class:`Record` objects. :param str query: Query text :param args: Query arguments
asyncpg/prepared_stmt.py:168
Method
fetch
r"""Return the next *n* rows as a list of :class:`Record` objects. :param float timeout: Optional timeout value in seconds. :return:
asyncpg/cursor.py:269
Method
fetchmany
Run a query for each sequence of arguments in *args* and return the results as a list of :class:`Record`. :param query: Q
asyncpg/connection.py:763
Method
fetchmany
Execute the statement and return a list of :class:`Record` objects. :param args: Query arguments. :param float timeout: Optional time
asyncpg/prepared_stmt.py:215
Method
fetchrow
Run a query and return the first row. :param str query: Query text :param args: Query arguments :para
asyncpg/connection.py:723
Method
fetchrow
Execute the statement and return the first row. :param str query: Query text :param args: Query arguments :param float timeou
asyncpg/prepared_stmt.py:200
Method
fetchrow
r"""Return the next row. :param float timeout: Optional timeout value in seconds. :return: A :class:`Record` instance.
asyncpg/cursor.py:287
Method
fetchval
Run a query and return a value in the first row. :param str query: Query text. :param args: Query arguments. :param int colum
asyncpg/connection.py:702
Method
finalize_options
(self)
setup.py:151
Function
flt
(log_record)
asyncpg/_testbase/__init__.py:32
Method
gen
()
tests/test_execute.py:239
Method
get_connection_spec
(self)
asyncpg/cluster.py:706
Method
get_connection_spec
(cls, kwargs)
asyncpg/_testbase/__init__.py:415
Method
get_connection_spec
(cls, kwargs={})
asyncpg/_testbase/__init__.py:517
Method
get_correctpassword
()
tests/test_connect.py:270
Method
get_data_dir
(self)
asyncpg/cluster.py:97
Method
get_max_size
(self)
asyncpg/connection.py:2513
Function
get_pg_home_directory
()
asyncpg/compat.py:26
Method
get_proxy_settings
(cls)
asyncpg/_testbase/__init__.py:391
Method
get_server_settings
(cls)
tests/test_connect.py:1798
Method
get_server_settings
(cls)
tests/test_introspection.py:47
Method
get_server_settings
(cls)
asyncpg/_testbase/__init__.py:385
Method
get_status
(self)
asyncpg/cluster.py:709
Method
get_wrongpassword
()
tests/test_connect.py:273
Method
get_xact_id
(con)
tests/test_pool.py:522
Function
guarded
A decorator to add a sanity check to ConnectionResource methods.
asyncpg/connresource.py:14
Method
handler
(loop, ctx)
asyncpg/_testbase/__init__.py:159
Method
hstore_decoder
(data)
tests/test_codecs.py:1192
Method
hstore_encoder
(obj)
tests/test_codecs.py:1201
Method
init
(con)
tests/test_pool.py:155
Method
init
Initialize cluster.
asyncpg/cluster.py:650
Method
init
(self, **settings)
asyncpg/cluster.py:712
Method
initialize_options
(self)
setup.py:122
Function
is_composite_type
(typeinfo: protocol.Record)
asyncpg/introspection.py:295
Function
is_domain_type
(typeinfo: protocol.Record)
asyncpg/introspection.py:291
Method
is_managed
(self)
asyncpg/cluster.py:703
Function
is_scalar_type
(typeinfo: protocol.Record)
asyncpg/introspection.py:284
Method
isempty
(self)
asyncpg/types.py:131
Method
kill_connectivity
()
tests/test_adversity.py:73
Method
listener1
(*args)
tests/test_listeners.py:27
Method
listener1
(*args)
tests/test_listeners.py:308
Method
listener2
(*args)
tests/test_listeners.py:30
Method
locker
()
tests/test_execute.py:275
Method
loop_exception_handler
(self, loop, context)
asyncpg/_testbase/__init__.py:179
Method
lower_inc
(self)
asyncpg/types.py:111
Method
lower_inf
(self)
asyncpg/types.py:115
Method
make_release_tree
(self, base_dir, files)
setup.py:95
Function
markcoroutinefunction
(c)
asyncpg/compat.py:57
Method
new
(cls, fields, query=None)
asyncpg/exceptions/_base.py:282
Method
notice_callb
(con, message)
tests/test_listeners.py:130
Method
query_saver
(record)
tests/test_logging.py:20
Method
raise_message
(level, code)
tests/test_listeners.py:274
Method
raise_notice
()
tests/test_listeners.py:142
Method
raise_warning
()
tests/test_listeners.py:149
Method
record_generator
()
tests/test_copy.py:688
Method
release
(self, timeout: Optional[float])
asyncpg/pool.py:195
Method
remove_termination_listener
Remove a listening callback for connection termination. :param callable callback: The callable or coroutine function that was pas
asyncpg/connection.py:218
Method
reset
(self, *, timeout=None)
tests/test_pool.py:32
Method
reset_hba
(self)
asyncpg/cluster.py:724
Method
run_in_subinterpreter
()
tests/test_subinterpreters.py:19
Method
setUp
(self)
tests/test_connect.py:146
Method
setUp
(self)
tests/test_execute.py:103
Method
setUp
(self)
tests/test_introspection.py:52
Method
setUp
(self)
asyncpg/_testbase/__init__.py:364
Method
setUp
(self)
asyncpg/_testbase/__init__.py:439
Method
setUpClass
(cls)
tests/test_connect.py:459
Method
setUpClass
(cls)
tests/test_introspection.py:30
Method
setUpClass
(cls)
asyncpg/_testbase/__init__.py:332
Method
setUpClass
(cls)
asyncpg/_testbase/__init__.py:395
Method
setup_cluster
(cls)
tests/test_codecs.py:1984
Method
setup_cluster
(cls)
tests/test_pool.py:1012
Method
setup_cluster
(cls)
tests/test_connect.py:430
Method
setup_cluster
(cls)
tests/test_connect.py:1813
Method
setup_cluster
(cls)
asyncpg/_testbase/__init__.py:459
Function
silence_asyncio_long_exec_warning
()
asyncpg/_testbase/__init__.py:31
Method
sleep_and_release
()
tests/test_pool.py:479
← previous
next →
401–500 of 868, ranked by callers