Sdílet prostřednictvím

Konfigurace zdrojové fáze InfluxDB v2

  • Článek

Důležité

Azure IoT Operations Preview – Služba Azure Arc je aktuálně ve verzi PREVIEW. Tento software ve verzi Preview byste neměli používat v produkčních prostředích.

Právní podmínky, které platí pro funkce Azure, které jsou ve verzi beta, verzi Preview nebo které zatím nejsou veřejně dostupné, najdete v Dodatečných podmínkách použití pro Microsoft Azure verze Preview.

Zdrojová fáze je první a požadovaná fáze kanálu zpracovatele dat Azure IoT (Preview). Zdrojová fáze získá data do kanálu zpracování dat a připraví je na další zpracování. Fáze zdroje InfluxDB umožňuje číst data z databáze InfluxDB v2 v uživatelsky definovaném intervalu.

Ve zdrojové fázi definujete:

  • Podrobnosti o připojení pro InfluxDB v2
  • Interval dotazování databáze InfluxDB. Fáze čeká na výsledek, než resetuje časovač intervalu.
  • Konfigurace dělení na základě vašich konkrétních požadavků na zpracování dat.

Požadavky

  • Nasazená instance procesoru dat Azure IoT Preview, která zahrnuje volitelnou komponentu Zpracovatel dat.
  • Databáze InfluxDB se všemi potřebnými nezpracovanými daty je funkční a dosažitelná.

Příprava databáze Influx

Pokud se chcete připojit k databázi InfluxDB, musíte:

  • Vytvořte přístupový token, který kanálu udělí přístup ke čtení databáze InfluxDB. Další informace najdete v tématu Správa tokenů rozhraní API.
  • Ve službě Azure Key Vault vytvořte tajný klíč, který obsahuje přístupový token. Další informace najdete v tématu Správa tajných kódů pro nasazení operací Azure IoT.

Konfigurace zdroje InfluxDB

Konfigurace zdroje InfluxDB:

  • Zadejte podrobnosti o databázi InfluxDB. Tato konfigurace zahrnuje název serveru a dotaz pro načtení dat.
  • Zadejte metodu ověřování. V současné době můžete použít pouze ověřování přístupového tokenu.

Následující tabulka popisuje parametry konfigurace zdroje InfluxDB:

Základní schéma vstupní konfigurace se skládá z:

Pole Typ Popis Povinné? Výchozí Příklad
Název String Název viditelný zákazníkem pro zdrojovou fázi. Požaduje se NA erp-database
Popis String Popis zdrojové fáze viditelný zákazníkem. Volitelné NA Enterprise database
Adresa URL databáze String Adresa URL databáze InfluxDB Ano https://contoso.com/some/url/path
Port databáze Celé číslo Port databáze InfluxDB No 443 443
Organizace String Organizace, která obsahuje kontejner, ze kterého se má dotazovat Ano test-org test-org
Ověřování Authentication type Metoda ověřování pro připojení k serveru. Podporuje accessToken pouze typ. Ano {"type": "accessToken"} {"type": "accessToken"}
Tajný String Odkaz na token uložený ve službě Azure Key Vault. Ano Yes AKV_ACCESS_TOKEN
Flux – dotaz String Dotaz InfluxDB Ano {"expression": 'from(bucket:"test-bucket")\|> range(start: -1h) \|> filter(fn: (r) => r._measurement == "stat")'}
Interval dotazu Doba trvání Řetězcové znázornění doby čekání před dalším voláním rozhraní API Ano 24h
Formát dat Formát Fáze použije formát na jednotlivé řádky načtené dotazem. json Podporuje se jenom formát. Nejvyšší úroveň path není podporovaná. Ano {"type": "json"}
dělení na části Segmentace Konfigurace dělení pro zdrojová fáze Požaduje se NA Viz dělení

Konfigurace dělení

Dělení v kanálu rozdělí příchozí data do samostatných oddílů. Dělení umožňuje paralelismus dat v kanálu, což může zlepšit propustnost a snížit latenci. Strategie dělení ovlivňují způsob zpracování dat v dalších fázích kanálu. Například poslední známá fáze hodnoty a agregační fáze pracují s každým logickým oddílem.

Pokud chcete data rozdělit, zadejte strategii dělení a počet oddílů, které se mají použít:

Pole Popis Požaduje se Výchozí Příklad
Typ oddílu Typ dělení, který se má použít: Oddíl ID nebo Oddíl Key Požaduje se ID ID
Výraz oddílu Výraz jq, který se má použít pro příchozí zprávu k výpočtu oddílu ID nebo oddíluKey Požaduje se 0 .payload.header
Počet oddílů Počet oddílů v kanálu zpracovatele dat. Požaduje se 1 1

Zpracovatel dat přidá do příchozí zprávy metadata. V přehledu struktury zpráv zpracovatele dat se dozvíte, jak správně určit výraz dělení, který běží na příchozí zprávě. Ve výchozím nastavení je výraz dělení nastaven na 0typ Oddíl, aby ID se všechny příchozí data odesílala do jednoho oddílu.

Doporučení a další informace najdete v tématu Co je dělení?.

Vzorová konfigurace

Následující příklad JSON ukazuje úplnou konfiguraci zdrojové fáze InfluxDB:

{
  "displayName": "InfluxDB v2 - ec8750",
  "type": "input/influxdbv2@v1",
  "query": {
    "expression": "from(bucket:\\\"test-bucket\\\") |> range(start: -1h) |> filter(fn: (r) => r._measurement == \\\"stat\\\")"
  },
  "url": "https://contoso.com/some/url/path",
  "interval": "5s",
  "port": 443,
  "organization": "test-org",
  "format": {
    "type": "json"
  },
  "partitionCount": 1,
  "partitionStrategy": {
    "type": "id",
    "expression": "0"
  },
  "authentication": {
    "type": "accessToken",
    "accessToken": "AKV_ACCESS_TOKEN"
  },
  "description": "Example InfluxDB source stage"
}

Související obsah