Register a portfolio with thousands of companies and receive the right news

curl -sS -X POST https://api.businessradar.com/ext/v3/portfolios \
  -H "Authorization: Bearer $BUSINESSRADAR_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{
    "name": "Suppliers EU",
    "customer_reference": "erp-suppliers-eu",
    "default_permission": "view_only"
  }'

portfolio = client.portfolios.create(
    name="Suppliers EU",
    customer_reference="erp-suppliers-eu",
    default_permission="view_only",
)
print(portfolio.external_id)

const portfolio = await client.portfolios.create({
  name: 'Suppliers EU',
  customer_reference: 'erp-suppliers-eu',
  default_permission: 'view_only',
});
console.log(portfolio.external_id);

<?php

$portfolio = $client->portfolios->create(
    name: 'Suppliers EU',
    customerReference: 'erp-suppliers-eu',
    defaultPermission: 'view_only',
);
echo $portfolio->external_id, PHP_EOL;

curl -sS -X POST \
  "https://api.businessradar.com/ext/v3/portfolios/$PORTFOLIO_ID/companies" \
  -H "Authorization: Bearer $BUSINESSRADAR_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{
    "duns_number": "123456789",
    "customer_reference": "erp-4711",
    "submit_investigation_when_not_identified": true
  }'

registration = client.portfolios.companies.create(
    portfolio.external_id,
    duns_number="123456789",
    customer_reference="erp-4711",
    submit_investigation_when_not_identified=True,
)

const registration = await client.portfolios.companies.create(portfolio.external_id, {
  duns_number: '123456789',
  customer_reference: 'erp-4711',
  submit_investigation_when_not_identified: true,
});

<?php

$registration = $client->portfolios->companies->create(
    $portfolio->external_id,
    dunsNumber: '123456789',
    customerReference: 'erp-4711',
    submitInvestigationWhenNotIdentified: true,
);

import concurrent.futures
import csv

import businessradar

def register(row: dict[str, str]) -> str:
    registration = client.portfolios.companies.create(
        portfolio.external_id,
        duns_number=row["duns"] or None,
        primary_name=row["name"] or None,
        country=row["country"] or None,
        customer_reference=row["reference"],
        submit_investigation_when_not_identified=True,
    )
    return registration.external_id

with open("companies.csv") as handle:
    rows = list(csv.DictReader(handle))

# Eight in flight is plenty: the work is queued server-side anyway.
with concurrent.futures.ThreadPoolExecutor(max_workers=8) as pool:
    for row, future in [(row, pool.submit(register, row)) for row in rows]:
        try:
            print(row["reference"], future.result())
        except businessradar.RateLimitError:
            print(row["reference"], "throttled — retry this row later")

const rows = await loadCompanies(); // your CSV, database, whatever

const CONCURRENCY = 8;
for (let offset = 0; offset < rows.length; offset += CONCURRENCY) {
  const batch = rows.slice(offset, offset + CONCURRENCY);
  const results = await Promise.allSettled(
    batch.map((row) =>
      client.portfolios.companies.create(portfolio.external_id, {
        duns_number: row.duns ?? null,
        primary_name: row.name ?? null,
        country: row.country ?? null,
        customer_reference: row.reference,
        submit_investigation_when_not_identified: true,
      }),
    ),
  );
  for (const [index, result] of results.entries()) {
    if (result.status === 'rejected') {
      console.error(batch[index].reference, result.reason);
    }
  }
}

<?php

use Businessradar\Core\Exceptions\RateLimitException;

foreach ($rows as $row) {
    try {
        $registration = $client->portfolios->companies->create(
            $portfolio->external_id,
            dunsNumber: $row['duns'] ?: null,
            primaryName: $row['name'] ?: null,
            country: $row['country'] ?: null,
            customerReference: $row['reference'],
            submitInvestigationWhenNotIdentified: true,
        );
        echo $row['reference'], ' ', $registration->external_id, PHP_EOL;
    } catch (RateLimitException $e) {
        sleep(5); // and retry this row on the next pass
    }
}

curl -sS -X POST https://api.businessradar.com/ext/v3/webhooks/ \
  -H "Authorization: Bearer $BUSINESSRADAR_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{
    "url": "https://example.com/hooks/businessradar",
    "enabled": true,
    "subscriptions": [
      { "event_type": "company_registration.status_registered" },
      { "event_type": "company.updated", "portfolio": "'"$PORTFOLIO_ID"'" }
    ]
  }'

webhook = client.webhooks.create(
    url="https://example.com/hooks/businessradar",
    enabled=True,
    subscriptions=[
        {"event_type": "company_registration.status_registered"},
        {"event_type": "company.updated", "portfolio": portfolio.external_id},
    ],
)
# The secret is shown once, here. Store it before you do anything else.

const webhook = await client.webhooks.create({
  url: 'https://example.com/hooks/businessradar',
  enabled: true,
  subscriptions: [
    { event_type: 'company_registration.status_registered' },
    { event_type: 'company.updated', portfolio: portfolio.external_id },
  ],
});

<?php

$webhook = $client->webhooks->create(
    subscriptions: [
        ['eventType' => 'company_registration.status_registered'],
        ['eventType' => 'company.updated', 'portfolio' => $portfolio->external_id],
    ],
    url: 'https://example.com/hooks/businessradar',
    enabled: true,
);

curl -sS -G https://api.businessradar.com/ext/v3/articles \
  -H "Authorization: Bearer $BUSINESSRADAR_API_KEY" \
  --data-urlencode "portfolio_id=$PORTFOLIO_ID" \
  --data-urlencode "is_material=true" \
  --data-urlencode "min_creation_date=2026-09-17T08:00:00Z" \
  --data-urlencode "sorting=priority" \
  --data-urlencode "sorting_order=desc"

page = client.news.articles.list(
    portfolio_id=[portfolio.external_id],
    is_material=True,
    min_creation_date="2026-09-17T08:00:00Z",
    sorting="priority",
    sorting_order="desc",
)
for article in page.results:
    print(article.publication_datetime, article.title, article.url)

const page = await client.news.articles.list({
  portfolio_id: [portfolio.external_id],
  is_material: true,
  min_creation_date: '2026-09-17T08:00:00Z',
  sorting: 'priority',
  sorting_order: 'desc',
});
for (const article of page.results) {
  console.log(article.publication_datetime, article.title, article.url);
}

<?php

$page = $client->news->articles->list(
    portfolioID: [$portfolio->external_id],
    isMaterial: true,
    minCreationDate: new DateTimeImmutable('2026-09-17T08:00:00Z'),
    sorting: 'priority',
    sortingOrder: 'desc',
);
foreach ($page->getItems() as $article) {
    echo $article->title, PHP_EOL;
}

curl -sS -G https://api.businessradar.com/ext/v3/articles \
  -H "Authorization: Bearer $BUSINESSRADAR_API_KEY" \
  --data-urlencode "portfolio_id=$PORTFOLIO_ID" \
  --data-urlencode "next_key=eyJvZmZzZXQiOjUwfQ"

seen = 0
for article in client.news.articles.list(
    portfolio_id=[portfolio.external_id],
    min_creation_date=last_polled_at,
):
    seen += 1  # pages are fetched as the iterator needs them
print(seen)

for await (const article of client.news.articles.list({
  portfolio_id: [portfolio.external_id],
  min_creation_date: lastPolledAt,
})) {
  await store(article);
}

<?php

$page = $client->news->articles->list(portfolioID: [$portfolio->external_id]);
foreach ($page->pagingEachItem() as $article) {
    // fetches further pages as needed
    store($article);
}

#!/usr/bin/env bash
set -euo pipefail

: "${BUSINESSRADAR_API_KEY:?export your API key first}"
BASE=https://api.businessradar.com/ext/v3
AUTH="Authorization: Bearer $BUSINESSRADAR_API_KEY"
STATE=.last_polled_at

portfolio=$(curl -fsS -X POST "$BASE/portfolios" \
  -H "$AUTH" -H "Content-Type: application/json" \
  -d '{"name": "Suppliers EU", "customer_reference": "erp-suppliers-eu"}' \
  | jq -r '.external_id')

# companies.csv: duns,name,country,reference
tail -n +2 companies.csv | while IFS=, read -r duns name country reference; do
  curl -fsS -X POST "$BASE/portfolios/$portfolio/companies" \
    -H "$AUTH" -H "Content-Type: application/json" \
    -d "$(jq -n \
      --arg duns "$duns" --arg name "$name" \
      --arg country "$country" --arg reference "$reference" \
      '{duns_number: ($duns | select(. != "")),
        primary_name: ($name | select(. != "")),
        country: ($country | select(. != "")),
        customer_reference: $reference,
        submit_investigation_when_not_identified: true}')" >/dev/null
done

since=$(cat "$STATE" 2>/dev/null || date -u -v-1d +%Y-%m-%dT%H:%M:%SZ)
now=$(date -u +%Y-%m-%dT%H:%M:%SZ)

next_key=""
while :; do
  response=$(curl -fsS -G "$BASE/articles" -H "$AUTH" \
    --data-urlencode "portfolio_id=$portfolio" \
    --data-urlencode "is_material=true" \
    --data-urlencode "min_creation_date=$since" \
    ${next_key:+--data-urlencode "next_key=$next_key"})

  echo "$response" | jq -r '.results[] | "\(.publication_datetime)\t\(.title)"'

  next_key=$(echo "$response" | jq -r '.next_key // empty')
  [ -z "$next_key" ] && break
done

echo "$now" > "$STATE"

import concurrent.futures
import csv
import datetime
import os
import pathlib

import businessradar
from businessradar import BusinessRadar

client = BusinessRadar(api_key=os.environ["BUSINESSRADAR_API_KEY"])
state = pathlib.Path(".last_polled_at")

portfolio = client.portfolios.create(
    name="Suppliers EU",
    customer_reference="erp-suppliers-eu",
)

def register(row: dict[str, str]) -> str:
    registration = client.portfolios.companies.create(
        portfolio.external_id,
        duns_number=row["duns"] or None,
        primary_name=row["name"] or None,
        country=row["country"] or None,
        customer_reference=row["reference"],
        submit_investigation_when_not_identified=True,
    )
    return registration.external_id

with open("companies.csv") as handle:
    rows = list(csv.DictReader(handle))

with concurrent.futures.ThreadPoolExecutor(max_workers=8) as pool:
    for row, future in [(row, pool.submit(register, row)) for row in rows]:
        try:
            future.result()
        except businessradar.RateLimitError:
            print(row["reference"], "throttled — retry this row later")

now = datetime.datetime.now(datetime.timezone.utc)
since = (
    state.read_text().strip()
    if state.exists()
    else (now - datetime.timedelta(days=1)).isoformat()
)

for article in client.news.articles.list(
    portfolio_id=[portfolio.external_id],
    is_material=True,
    min_creation_date=since,
):
    print(article.publication_datetime, article.title)

state.write_text(now.isoformat())

import fs from 'node:fs/promises';
import BusinessRadar from '@businessradar/businessradar';

const client = new BusinessRadar({ apiKey: process.env['BUSINESSRADAR_API_KEY'] });
const STATE = '.last_polled_at';
const CONCURRENCY = 8;

const portfolio = await client.portfolios.create({
  name: 'Suppliers EU',
  customer_reference: 'erp-suppliers-eu',
});

const rows = await loadCompanies(); // your CSV, database, whatever

for (let offset = 0; offset < rows.length; offset += CONCURRENCY) {
  const batch = rows.slice(offset, offset + CONCURRENCY);
  const results = await Promise.allSettled(
    batch.map((row) =>
      client.portfolios.companies.create(portfolio.external_id, {
        duns_number: row.duns ?? null,
        primary_name: row.name ?? null,
        country: row.country ?? null,
        customer_reference: row.reference,
        submit_investigation_when_not_identified: true,
      }),
    ),
  );
  for (const [index, result] of results.entries()) {
    if (result.status === 'rejected') {
      console.error(batch[index].reference, result.reason);
    }
  }
}

const now = new Date().toISOString();
const since = await fs
  .readFile(STATE, 'utf8')
  .then((value) => value.trim())
  .catch(() => new Date(Date.now() - 86_400_000).toISOString());

for await (const article of client.news.articles.list({
  portfolio_id: [portfolio.external_id],
  is_material: true,
  min_creation_date: since,
})) {
  console.log(article.publication_datetime, article.title);
}

await fs.writeFile(STATE, now);

<?php

require 'vendor/autoload.php';

use Businessradar\Client;
use Businessradar\Core\Exceptions\RateLimitException;

$client = new Client(apiKey: getenv('BUSINESSRADAR_API_KEY'));
$state = '.last_polled_at';

$portfolio = $client->portfolios->create(
    name: 'Suppliers EU',
    customerReference: 'erp-suppliers-eu',
);

$handle = fopen('companies.csv', 'r');
$columns = fgetcsv($handle);
while ($line = fgetcsv($handle)) {
    $row = array_combine($columns, $line);
    try {
        $client->portfolios->companies->create(
            $portfolio->external_id,
            dunsNumber: $row['duns'] ?: null,
            primaryName: $row['name'] ?: null,
            country: $row['country'] ?: null,
            customerReference: $row['reference'],
            submitInvestigationWhenNotIdentified: true,
        );
    } catch (RateLimitException $e) {
        sleep(5); // and retry this row on the next pass
    }
}
fclose($handle);

$now = new DateTimeImmutable('now', new DateTimeZone('UTC'));
$since = file_exists($state)
    ? new DateTimeImmutable(trim(file_get_contents($state)))
    : $now->modify('-1 day');

$page = $client->news->articles->list(
    isMaterial: true,
    minCreationDate: $since,
    portfolioID: [$portfolio->external_id],
);
foreach ($page->pagingEachItem() as $article) {
    echo $article->publication_datetime, ' ', $article->title, PHP_EOL;
}

file_put_contents($state, $now->format(DATE_ATOM));