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)