Ustawianie wartości zwracanej potoku w usługach Azure Data Factory i Azure Synapse Analytics

DOTYCZY: Azure Data Factory Azure Synapse Analytics

W paradygmacie wywoływania potoku podrzędnego można użyć działania Ustaw zmienną, aby zwrócić wartości z potoku podrzędnego do potoku wywołującego. W poniższym scenariuszu mamy podręczny potok uruchamiany za pomocą działania uruchamiania potoku. Chcemy pobrać informacje z potoku podrzędnego, do następnego użycia w potoku wywołującym.

Wprowadź wartość zwracaną potoku, słownik par klucz-wartość, który umożliwia komunikację między potokami podrzędnymi i potokiem nadrzędnym.

Warunek wstępny — wywoływanie potoku podrzędnego

Zgodnie z wymaganiami wstępnymi projekt wymaga aktywności Uruchom potok, która wywołuje potok podrzędny z włączoną opcją Oczekiwanie na ukończenie w aktywności.

Konfigurowanie wartości zwracanej potoku w potoku podrzędnym

Rozszerzyliśmy aktywność 'Ustaw zmienną' o zmienne systemowe 'Wartość zwracana potoku'. Nie musisz definiować ich na poziomie potoku (w przeciwieństwie do innych zmiennych używanych w potoku).

1. Wyszukaj pozycję Ustaw zmienną w okienku Działania potoku i przeciągnij działanie Ustaw zmienną na kanwę potoku.
2. Wybierz działanie Ustaw zmienną w obszarze roboczym, jeśli nie zostało jeszcze wybrane, a następnie kartę Zmienne, aby edytować szczegóły.
3. Wybierz wartość zwrotną potoku dla typu zmiennej.
4. Wybierz pozycję Nowy , aby dodać nową parę wartości klucza.
5. Liczba par klucz-wartość, które można dodać, jest ograniczona tylko przez limit rozmiaru zwracanego kodu JSON (4 MB).

Istnieje kilka opcji dla typów wartości, w tym

Wartość typu obiektu jest definiowana w następujący sposób:

[{"key": "myKey1", "value": {"type": "String", "content": "hello world"}}, 
 {"key": "myKey2", "value": {"type": "String", "content": "hi"}}
]

Pobieranie wartości w potoku wywołań

Wartość zwracana potoku podrzędnego staje się danymi wyjściowymi działania Wykonaj Działanie Potoku. Informacje można pobrać za pomocą @activity('Execute Pipeline1').output.pipelineReturnValue.keyName. Przypadek użycia jest nieograniczony. Można na przykład użyć

• Wartość int z potoku podrzędnego do zdefiniowania okresu oczekiwania dla aktywności oczekiwania.
• Wartość ciągu służąca do zdefiniowania adresu URL działania sieci Web.
• Ładunek wartości wyrażenia dla działania skryptu na potrzeby rejestrowania.

Istnieją dwa zauważalne objaśnienia dotyczące zwracanych wartości potoku.

1. Za pomocą typu obiektu można dodatkowo rozwinąć zagnieżdżony obiekt json, taki jak @activity('Execute Pipeline1').output.pipelineReturnValue.keyName.nextLevelKey
2. Za pomocą typu tablicy można określić indeks w tablicy za pomocą @activity('Execute Pipeline1').output.pipelineReturnValue.keyName[0]. Liczba jest indeksowana od zera, co oznacza, że zaczyna się od 0.

Kwestie szczególne

• Chociaż w rurze można uwzględnić wiele aktywności Ustaw Wartość Zwracaną Rur, ważne jest, aby upewnić się, że w przepływie wykonywana jest tylko jedna z nich.

  

  Aby uniknąć opisanego wcześniej problemu z brakiem klucza podczas pracy z potokami, zalecamy posiadanie tej samej listy kluczy dla wszystkich gałęzi w potokach podrzędnych. Rozważ użycie typów null dla kluczy, które nie mają wartości w określonej gałęzi.

• Język wyrażeń usługi Azure Data Factory nie obsługuje bezpośrednio wbudowanych obiektów JSON. Zamiast tego konieczne jest prawidłowe łączenie ciągów i wyrażeń.

  Na przykład dla następującego wyrażenia JSON:

  {
    "datetime": "@{utcnow()}",
    "date": "@{substring(utcnow(),0,10)}",
    "year": "@{substring(utcnow(),0,4)}",
    "month": "@{substring(utcnow(),5,2)}",
    "day": "@{substring(utcnow(),8,2)}"
  }
  

  Równoważne wyrażenie usługi Azure Data Factory to:

  @{
    concat(
      '{',
      '"datetime": "', utcnow(), '", ',
      '"date": "', substring(utcnow(),0,10), '", ',
      '"year": "', substring(utcnow(),0,4), '", ',
      '"month": "', substring(utcnow(),5,2), '", ',
      '"day": "', substring(utcnow(),8,2), '"',
      '}'
    )
  }
  

Powiązana zawartość

Dowiedz się więcej o innym powiązanym działaniu przepływu sterowania:

• Ustawianie działania zmiennej
• Działanie dodawania zmiennej