queries

queries

Seeder-specific database queries.

Classes

Functions

insert_relays async

insert_relays(brotr: Brotr, relays: list[Relay]) -> int

Bulk-insert relays directly into the relay table.

Delegates to batched_insert to respect the configured batch size. Duplicates are silently skipped (ON CONFLICT DO NOTHING).

Parameters:

• brotr (Brotr) –

  Brotr database interface.

• relays (list[Relay]) –

  Relay objects to insert.

Returns:

• int –

  Number of relays actually inserted.

Source code in src/bigbrotr/services/seeder/queries.py

async def insert_relays(brotr: Brotr, relays: list[Relay]) -> int:
    """Bulk-insert relays directly into the ``relay`` table.

    Delegates to [batched_insert][bigbrotr.services.common.queries.batched_insert]
    to respect the configured batch size. Duplicates are silently skipped
    (``ON CONFLICT DO NOTHING``).

    Args:
        brotr: [Brotr][bigbrotr.core.brotr.Brotr] database interface.
        relays: [Relay][bigbrotr.models.relay.Relay] objects to insert.

    Returns:
        Number of relays actually inserted.
    """
    return await batched_insert(brotr, relays, brotr.insert_relay)