|
1 | 1 | --- |
2 | 2 | title: Kestra integration |
3 | | -description: Connect Apify with Kestra to orchestrate workflows — run Flows, extract structured data, and react to Actor or task events in real time. |
| 3 | +description: Connect Apify with Kestra to orchestrate workflows — run flows, extract structured data, and react to Actor or task events in real time. |
4 | 4 | sidebar_label: Kestra |
5 | 5 | sidebar_position: 7 |
6 | 6 | slug: /integrations/kestra |
7 | 7 | --- |
8 | 8 |
|
9 | | -**Connect Apify with Kestra to orchestrate workflows — run Flows, extract structured data, and react to Actor or task events in real time.** |
| 9 | +**Connect Apify with Kestra to orchestrate workflows — run flows, extract structured data, and react to Actor or task events in real time.** |
10 | 10 |
|
11 | 11 | --- |
12 | 12 |
|
13 | 13 | [Kestra](https://kestra.io/) is an open-source, event-driven orchestration platform that unifies workflows for all engineers. |
14 | | -With the [Apify plugin for Kestra](https://github.com/apify/kestra-plugin-apify), you can seamlessly connect Apify Actors and storage to your workflows. |
| 14 | +With the [Apify plugin for Kestra](https://github.com/kestra-io/plugin-kestra), you can seamlessly connect Apify Actors and storage to your workflows. |
15 | 15 | Run scrapers, extract structured data — all defined declaratively in YAML and orchestrated directly from the UI. |
16 | | -In this guide, you'll learn how to set up authentication and incorporate it into a Kestra flows. |
| 16 | +In this guide, you'll learn how to set up and incorporate authentication into a Kestra flows. |
17 | 17 |
|
18 | 18 | ## Prerequisites |
19 | 19 |
|
20 | 20 | Before you begin, make sure you have: |
21 | 21 |
|
22 | 22 | - An [Apify account](https://console.apify.com/) |
23 | | -- An [Kestra instance](https://kestra.io/docs/getting-started/quickstart) (self‑hosted or cloud) |
| 23 | +- A [Kestra instance](https://kestra.io/docs/getting-started/quickstart) (self‑hosted or cloud) |
24 | 24 |
|
25 | 25 | Once installed, the next step is authentication. |
26 | 26 |
|
@@ -50,15 +50,15 @@ or fetching data. |
50 | 50 | Tasks allow you to perform operations like running an Actor within a workflow. |
51 | 51 |
|
52 | 52 | 1. Create a new flow. |
53 | | -1. Inside the **Flow code** tab change the hello tasks type to be **io.kestra.plugin.apify.actor.Run**. |
54 | | -1. Change the tasks id to be **run_apify_actor** |
| 53 | +1. Inside the **Flow code** tab change the hello task's type to be **io.kestra.plugin.apify.actor.Run**. |
| 54 | +1. Change the task's id to be **run_apify_actor** |
55 | 55 | 1. Remove the message property. |
56 | 56 | 1. Configure the **run_apify_actor** task by adding your required values for the properties listed below: |
57 | 57 | - **actor id**: Actor ID or a tilde-separated owner's username and Actor name. |
58 | 58 | - **apiToken**: A reference to the secret value you set up earlier. For example "\{\{secret(namespace=flow.namespace, key='APIFY_API_KEY')\}\}" |
59 | 59 | 1. Add a new task below the **run_apify_actor** with an ID of **get_dataset** and a type of **io.kestra.plugin.apify.dataset.Get**.: |
60 | 60 | 1. Configure the **get_dataset** to fetch the dataset generated by the **run_apify_actor** task by configuring the following values: |
61 | | - - **datasetId**: The Id of the dataset to fetch. You can use the value from the previous task using the following syntax: "\{\{secret(namespace=flow.namespace, key='APIFY_API_KEY')\}\}" |
| 61 | + - **datasetId**: The ID of the dataset to fetch. You can use the value from the previous task using the following syntax: "\{\{secret(namespace=flow.namespace, key='APIFY_API_KEY')\}\}" |
62 | 62 | - **apiToken**: A reference to the secret value you set up earlier. For example '\{\{secret(namespace=flow.namespace, key='APIFY_API_KEY')\}\}' |
63 | 63 | - **input**: Input for the Actor run. The input is optional and can be used to pass data to the Actor. For our example we will add 'hashtags: ["fyp"]' |
64 | 64 | - **maxItems**: The maximum number of items to fetch from the dataset. For our example we will set this to 5. |
|
0 commit comments