Introducción a planes
Un plan permite la ejecución de una secuencia de tareas discretas en Alteryx Analytics Cloud (AAC). Estas tareas pueden ser de flujo, de flujo de trabajo, solicitudes HTTP a otras plataformas y mucho más. La secuencia de tareas se puede sincronizar en función de criterios de éxito o falla y se puede reiniciar si es necesario cuando el plan ha fallado.
Un plan permite la ejecución de una secuencia de tareas discretas en Alteryx Analytics Cloud (AAC). Estas tareas pueden ser de flujo, de flujo de trabajo, solicitudes HTTP a otras plataformas y mucho más. La secuencia de tareas se puede sincronizar en función de criterios de éxito o falla y se puede reiniciar si es necesario cuando el plan ha fallado.
Vista general
En muchas situaciones, los pipelines de datos tienen dependencias en ellos. Se deben limpiar los datos obtenidos de un conjunto determinado y entregarlos a otro pipeline de datos para su uso. Cuando se crea un pipeline, se debe programar su ejecución periódica. Lo ideal es que, cuando se complete la ejecución, se informe a los stakeholders posteriores que la ejecución del pipeline se realizó correctamente o presentó fallas.
En AAC, los planes proporcionan el mecanismo para construir estos pipelines de datos sólidos en la aplicación, en los que se pueden ejecutar secuencias de tareas a fin de ofrecer conjuntos de datos más diversos. Como resultado de las ejecuciones correctas o con fallas, AAC puede enviar mensajes a aplicaciones receptoras, como Slack.
Terms
Term | Description |
|---|---|
plan | A plan is a sequence of tasks that are executed from the platform or on assets to which you have access. To orchestrate tasks, you build a plan. A plan can be scheduled for execution, triggered manually, or invoked via API. |
trigger | A task is executed based on a trigger. A trigger is a condition under which a task is executed. In many cases, the trigger for a task is based on the schedule for the plan. |
task | A task is a unit of execution in the platform. |
snapshot | A snapshot of the plan is captured, and the plan is executed against this snapshot. For more information on snapshots, see "Plan execution" below. |
Sugerencia
Como una de las tareas del plan, puedes configurar un mensaje HTTP, que te permite activar los puntos de conexión en AAC mismo. Por lo tanto, puedes configurar las ejecuciones de tu plan para activar una gran variedad de actividades en el producto en sí.
Ejemplo
En el siguiente ejemplo, se muestra cómo crear un plan que ejecute las siguientes tareas:
Ejecuta la tarea que realiza la limpieza inicial de tus datos. Los datos de resultados se guardan en una ubicación conocida.
Ejecuta la tarea que transforma los datos limpios para usos posteriores.
Según los resultados del paso 2:
Si se realiza correctamente: envía un mensaje de éxito a un canal de Slack.
Si ocurren fallas: envía un mensaje de error a un canal de Slack.
En la vista Plan, este plan puede tener la siguiente apariencia:
Figura: Un plan con una secuencia de tareas
Después de crear el plan anterior, puedes realizar las ejecuciones de prueba.
Si las pruebas se realizan correctamente, puedes programar la ejecución periódica del plan.
Task Types
The following tasks are available:
Workflow task: Execute one of your Designer Cloud workflows as part of a plan that you create in AACAAC. Go to Plan View for Workflow Tasks.
Desktop Workflow task: Orchestrate the execution of your Designer Desktop workflows that were uploaded to AACAAC. Go to Plan View for Desktop Workflow Tasks
Report task: Create and export a report from the data you've prepped and blended in AACAAC. Go to Plan View for Report Tasks.
Flow task: Generate all of the defined output objects for a flow. Go to Plan View for Flow Tasks.
ML Prediction task: Make predictions on new data with your Machine Learning project. Go to Plan View for ML Prediction Tasks.
ML Upload task: Upload new training data to your Machine Learning project. Go to Plan View for ML Upload Tasks.
HTTP task: Execute a task over HTTP protocol. Go to Plan View for HTTP Tasks.
Slack task: Send a message from AACAAC to a specified Slack channel. Go to Plan View for Slack Tasks.
Location Intelligence task: Orchestrate your Location Intelligence projects with other tasks. For more information, go to Plan View for Location Intelligence Tasks.
Intercambio de datos entre tareas
Puedes interactuar con las tareas en Plans utilizando directamente la salida de una tarea ascendente del flujo de trabajo como entrada para una tarea descendente, lo que permite anulaciones sin interrupciones.
Intercambios admitidos:
Designer Cloud → Predicción de Machine Learning
HTTP → Tarea de Flujo de trabajo
Tarea de Flujo de trabajo → HTTP
Tarea de Flujo de trabajo → Tarea Flujo de trabajo
El esquema de la salida de anulación debe ser el mismo que la entrada que está anulando.
Limitaciones:
Para el intercambio de tareas de Flujo de trabajo a tareas de Flujo de trabajo, la salida ascendente debe estar en formato CSV, mientras que la entrada descendente puede estar en cualquier formato.
Fusión de tareas
Para crear una lógica de ejecución de tareas adicional, conecta la salida de varias tareas ascendentes a la entrada de una sola tarea. La tarea resultante de una fusión espera hasta que se completen todas las tareas conectadas ascendentes antes de ejecutarse. La fusión también pasa salidas de flujo de trabajo relevantes o metadatos de tareas de todas las tareas ascendentes fusionadas. Por ejemplo, si conectas 2 tareas de flujo de trabajo a una tarea de Slack, puedes usar los metadatos (por ejemplo, la duración de flujo de trabajo o la hora de finalización) de ambos flujos de trabajo en el mensaje de Slack.
Para obtener más información sobre cómo crear y administrar tus planes, consulta Tareas del plan.
Overview of Orchestration
Orchestration is a set of functionalities that supports the scheduled execution of task sequences in the Alteryx Analytics Cloud. These tasks could be external processes, data transformation jobs, HTTP requests, and more.
In the following sections, you can review short summaries of specific features and explore more detailed information on them.
Limitations
You cannot specify parameter overrides to be applied to plans specifically.
Plans inherit parameter values from the objects referenced in the plan's tasks.
If overrides are applied to parameters inside of assets in a plan, those overrides are passed to the plan at the time of task execution.
Compatibilidad con parametrización limitada
Plans solo admite la parametrización de flujos de Trifacta Classic en este momento.
Basic Task
You create a plan and schedule it using the following basic tasks.
Create the plan. A plan is a container for definition of the tasks, triggers, and other objects. See Página Plans.
In Plan View, you specify the objects that are part of your plan. See Build Plans.
Schedule: The schedule defines the set of triggers that queue the plan for execution.
Trigger: A trigger defines the schedule and frequency at which the plan is executed. A plan can have multiple triggers (e.g. monthly versus weekly executions).
Task(s): Next, you specify the tasks that are executed in order.
As needed, you can apply override values to any flow parameters. These overrides are applied during a plan run. For more information, see Manage Plans Parameters.
Compatibilidad con parametrización limitada
Plans solo admite la parametrización de flujos de Trifacta Classic en este momento.
To test:
Select Run now.
To track progress, select the Runs link.
In the Run Details page, you can track the progress.
The first task is executed and completes, before the second task is started.
Individual tasks are executed as separate jobs, which you can track through the Job History page. See Job History Page.
When the plan has completed, you can verify the results through the Job details page. See Job Details Page.
If you are satisfied with the plan definition and your test run, the plan will execute according to the scheduled trigger.
Plan Scheduling
Through the Plan View page, you can configure the scheduled executions of the plan. Plan schedules are defined using triggers.
These schedules are independent of schedules for other asset types.
You cannot create schedules for individual tasks.
For more information, go to Programaciones.
Plan Execution
When a plan is triggered for execution, a snapshot of the plan is taken. This snapshot is used to execute the plan. Tasks are executed in the sequence listed in Plan View.
Important notes:
At the flow level, you can define webhooks and email notifications that are triggered based on the successful generation of outputs. When you execute a plan containing an output with one of these messages, the message is triggered and delivered to stakeholders.
Nota
Webhook messages and email notifications cannot be directly triggered based on a plan's execution. However, you can create HTTP-based tasks to send messages based on a plan task's execution.
Sugerencia
When a flow email notification is triggered through a plan, the internal identifier for the plan is included in the email.
Enable
Enable the following setting:
Plans feature
Plan sharing, import, and export must also be enabled.
Logging
For more information on debugging plans, see Diagnose Failed Plan Runs.