d1_client.aio package¶
asyncio based utilities.
Although this directory is not a package, this __init__.py file is required for pytest to be able to reach test directories below this directory.
Submodules¶
d1_client.aio.async_client module¶
-
class
d1_client.aio.async_client.
AsyncDataONEClient
(base_url='https://cn.dataone.org/cn', timeout_sec=None, cert_pub_path=None, cert_key_path=None, disable_server_cert_validation=False, max_concurrent_connections=100, try_count=3, verify_tls=False, user_agent=None, charset=None)¶ Bases:
object
-
__init__
(base_url='https://cn.dataone.org/cn', timeout_sec=None, cert_pub_path=None, cert_key_path=None, disable_server_cert_validation=False, max_concurrent_connections=100, try_count=3, verify_tls=False, user_agent=None, charset=None)¶ Args:
base_url: timeout_sec: cert_pub_path: cert_key_path: disable_server_cert_validation: max_concurrent_connections: Limit on concurrent outgoing connections enforced internally by aiohttp. try_count:
-
property
session
¶
-
async
close
()¶
-
async
get
()¶ Retrieve the SciObj bytes and write them to a file or other stream.
- Parameters
file_stream – Open file-like object Stream to which the SciObj bytes will be written.
pid – str
vendor_specific – dict Custom HTTP headers to include in the request
See also
MNRead.get().
-
async
get_system_metadata
(pid, vendor_specific=None)¶
-
async
list_objects
(fromDate=None, toDate=None, formatId=None, identifier=None, replicaStatus=None, nodeId=None, start=0, count=100, vendor_specific=None)¶
-
async
get_log_records
(fromDate=None, toDate=None, event=None, pidFilter=None, idFilter=None, start=0, count=100, vendor_specific=None)¶
-
async
describe
(pid, vendor_specific=None)¶ Get headers describing an object.
-
async
synchronize
(pid, vendor_specific=None)¶ Send an object synchronization request to the CN.
-
async
list_nodes
(vendor_specific=None)¶
-
async
get_capabilities
(*arg_list, **arg_dict)¶
-
dump_headers
(header_dict)¶
-