Query

Usage

It exists two methods to query an aggregate:

• fetch_aggregate: Query a single key
• fetch_aggregates: Query all keys.

def fetch_aggregate(
    self,
    address: str,
    key: str) -> Coroutine[Any, Any, dict[str, dict]]
)

def fetch_aggregates(
    self,
    address: str,
    keys: Optional[Iterable[str]] = None
) -> Dict[str, Dict]:

Arguments

Parameter	Description
address	The address of the aggregate sought.
key	The identifier for the aggregate sought.

Example

Fetch aggregates

from aleph.sdk.client import AlephHttpClient
import asyncio
import ssl
import certifi

ssl_context = ssl.create_default_context(cafile=certifi.where())

async def main():
    async with AlephHttpClient(ssl_context=ssl_context) as client:
        aggregates = await client.fetch_aggregates(
            "0xbC80BeEcBd67549E70cb1C729e903818E6370D37",
        )
        return aggregates

aggregates = asyncio.run(main())

outputs: aggregate

{'profile': {'bio': 'Modify', 'name': 'modify on Ethereum'}, 'testing': {'bio': 'tester', 'name': 'Antony'}}

---

Fetch aggregate

from aleph.sdk.client import AlephHttpClient
import asyncio
import ssl
import certifi

ssl_context = ssl.create_default_context(cafile=certifi.where())

async def main():
    async with AlephHttpClient(ssl_context=ssl_context) as client:
        aggregate = await client.fetch_aggregate(
            "0xbC80BeEcBd67549E70cb1C729e903818E6370D37",
            "profile",
        )
        return aggregate

aggregate = asyncio.run(main())
print(aggregate)

output: aggregate

{'bio': 'Modify', 'name': 'modify on Ethereum'}

Note

It is also possible to retrieve an aggregate from the API endpoint like this.