Connectors
Databases & Data Warehouses
AWS Athena
Serverless SQL on data in S3: run queries, read results, and manage workgroups and catalogs
- Signs in with
- AWS access keys
- Runs on
- Cloud or On-Prem Worker
- Operations
- 70
- Ready-made triggers
- 0
Connect AWS Athena
- In Neblex open Connect › Connections and click New Connection.
- Search for AWS Athena and give the connection a clear name.
- Fill in the fields. Secret values are encrypted and never shown again.
- Click Test, then Create Connection.
| Field | What to enter |
|---|---|
| Access key IDRequiredSecret | The access key ID of an IAM user or role session. |
| Secret access keyRequiredSecret | The secret access key that belongs to the access key ID. |
| Session tokenOptionalSecret | Only for temporary credentials (an assumed role or federated session). |
| RegionRequired | The AWS Region of the Athena workgroups and data catalogs, for example us-east-1.Example: us-east-1 |
Use it in a flow
- Open a flow, open the node library and search for AWS Athena.
- Drag it onto the canvas and choose an Operation and your connection.
- Map the operation's fields from earlier steps, or click Map with Matt.
- Use Test this step to see what it returns, then save.
To start a flow from AWS Athena without a ready-made trigger: a Poll for changes trigger can check one of its list operations on a schedule and pass on only what is new; if AWS Athena can send webhooks, a Webhook trigger receives them at its own URL.
Operations
70 operations in 10 groups. Each one is a step you can add to a flow.
Capacity reservations8
Cancel capacity reservationcancelCapacityReservation | POST | Cancels the capacity reservation with the specified name. |
Create capacity reservationcreateCapacityReservation | POST | Creates a capacity reservation with the specified name and number of requested data processing units. |
Delete capacity reservationdeleteCapacityReservation | POST | Deletes a cancelled capacity reservation. |
Get capacity assignment configurationgetCapacityAssignmentConfiguration | POST | Gets the capacity assignment configuration for a capacity reservation, if one exists. |
Get capacity reservationgetCapacityReservation | POST | Returns information about the capacity reservation with the specified name. |
List capacity reservationslistCapacityReservations | POST | Lists the capacity reservations for the current account. |
Put capacity assignment configurationputCapacityAssignmentConfiguration | POST | Puts a new capacity assignment configuration for a specified capacity reservation. |
Update capacity reservationupdateCapacityReservation | POST | Updates the number of requested data processing units for the capacity reservation with the specified name. |
Data catalogs9
Create data catalogcreateDataCatalog | POST | Creates (registers) a data catalog with the specified name and properties. |
Delete data catalogdeleteDataCatalog | POST | Deletes a data catalog. |
Get data cataloggetDataCatalog | POST | Returns the specified data catalog. |
Get databasegetDatabase | POST | Returns a database object for the specified database and data catalog. |
Get table metadatagetTableMetadata | POST | Returns table metadata for the specified catalog, database, and table. |
List data catalogslistDataCatalogs | POST | Lists the data catalogs in the current Amazon Web Services account. |
List databaseslistDatabases | POST | Lists the databases in the specified data catalog. |
List table metadatalistTableMetadata | POST | Lists the metadata for the tables in the specified data catalog database. |
Update data catalogupdateDataCatalog | POST | Updates the data catalog that has the specified name. |
Notebooks9
Create notebookcreateNotebook | POST | Creates an empty ipynb file in the specified Apache Spark enabled workgroup. |
Create presigned notebook urlcreatePresignedNotebookUrl | POST | Gets an authentication token and the URL at which the notebook can be accessed. |
Delete notebookdeleteNotebook | POST | Deletes the specified notebook. |
Export notebookexportNotebook | POST | Exports the specified notebook and its metadata. |
Get notebook metadatagetNotebookMetadata | POST | Retrieves notebook metadata for the specified notebook ID. |
Import notebookimportNotebook | POST | Imports a single ipynb file to a Spark enabled workgroup. |
List notebook metadatalistNotebookMetadata | POST | Displays the notebook files for the specified workgroup in paginated format. |
Update notebookupdateNotebook | POST | Updates the contents of a Spark notebook. |
Update notebook metadataupdateNotebookMetadata | POST | Updates the metadata for a notebook. |
Prepared statements6
Batch get prepared statementbatchGetPreparedStatement | POST | Returns the details of a single prepared statement or a list of up to 256 prepared statements for the array of prepared statement names that you provide. |
Create prepared statementcreatePreparedStatement | POST | Creates a prepared statement for use with SQL queries in Athena. |
Delete prepared statementdeletePreparedStatement | POST | Deletes the prepared statement with the specified name from the specified workgroup. |
Get prepared statementgetPreparedStatement | POST | Retrieves the prepared statement with the specified name from the specified workgroup. |
List prepared statementslistPreparedStatements | POST | Lists the prepared statements in the specified workgroup. |
Update prepared statementupdatePreparedStatement | POST | Updates a prepared statement. |
Query executions7
Batch get query executionbatchGetQueryExecution | POST | Returns the details of a single query execution or a list of up to 50 query executions, which you provide as an array of query execution ID strings. |
Get query executiongetQueryExecution | POST | Returns information about a single execution of a query if you have access to the workgroup in which the query ran. |
Get query resultsgetQueryResults | POST | Streams the results of a single query execution specified by QueryExecutionId from the Athena query results location in Amazon S3. |
Get query runtime statisticsgetQueryRuntimeStatistics | POST | Returns query execution runtime statistics related to a single execution of a query if you have access to the workgroup in which the query ran. |
List query executionslistQueryExecutions | POST | Provides a list of available query execution IDs for the queries in the specified workgroup. |
Start query executionstartQueryExecution | POST | Runs the SQL query statements contained in the Query . |
Stop query executionstopQueryExecution | POST | Stops a query execution. |
Saved queries6
Batch get named querybatchGetNamedQuery | POST | Returns the details of a single named query or a list of up to 50 queries, which you provide as an array of query ID strings. |
Create named querycreateNamedQuery | POST | Creates a named query in the specified workgroup. |
Delete named querydeleteNamedQuery | POST | Deletes the named query if you have access to the workgroup in which the query was saved. |
Get named querygetNamedQuery | POST | Returns information about a single query. |
List named querieslistNamedQueries | POST | Provides a list of available query IDs only for queries saved in the specified workgroup. |
Update named queryupdateNamedQuery | POST | Updates a NamedQuery object. |
Spark calculations6
Get calculation executiongetCalculationExecution | POST | Describes a previously submitted calculation execution. |
Get calculation execution codegetCalculationExecutionCode | POST | Retrieves the unencrypted code that was executed for the calculation. |
Get calculation execution statusgetCalculationExecutionStatus | POST | Gets the status of a current calculation. |
List calculation executionslistCalculationExecutions | POST | Lists the calculations that have been submitted to a session in descending order. |
Start calculation executionstartCalculationExecution | POST | Submits calculations for execution within a session. |
Stop calculation executionstopCalculationExecution | POST | Requests the cancellation of a calculation. |
Spark sessions9
Get sessiongetSession | POST | Gets the full details of a previously created session, including the session status and configuration. |
Get session endpointgetSessionEndpoint | POST | Gets a connection endpoint and authentication token for a given session Id. |
Get session statusgetSessionStatus | POST | Gets the current status of a session. |
List application DPU sizeslistApplicationDPUSizes | POST | Returns the supported DPU sizes for the supported application runtimes (for example, Athena notebook version 1 ). |
List executorslistExecutors | POST | Lists, in descending order, the executors that joined a session. |
List notebook sessionslistNotebookSessions | POST | Lists, in descending order, the sessions that have been created in a notebook that are in an active state like CREATING , CREATED , IDLE or BUSY . |
List sessionslistSessions | POST | Lists the sessions in a workgroup that are in an active state like CREATING , CREATED , IDLE , or BUSY . |
Start sessionstartSession | POST | Creates a session for running calculations within a workgroup. |
Terminate sessionterminateSession | POST | Terminates an active session. |
Tags3
List tags for resourcelistTagsForResource | POST | Lists the tags associated with an Athena resource. |
Tag resourcetagResource | POST | Adds one or more tags to an Athena resource. |
Untag resourceuntagResource | POST | Removes one or more tags from an Athena resource. |
Workgroups7
Create work groupcreateWorkGroup | POST | Creates a workgroup with the specified name. |
Delete work groupdeleteWorkGroup | POST | Deletes the workgroup with the specified name. |
Get resource dashboardgetResourceDashboard | POST | Gets the Live UI/Persistence UI for a session. |
Get work groupgetWorkGroup | POST | Returns information about the workgroup with the specified name. |
List engine versionslistEngineVersions | POST | Returns a list of engine versions that are available to choose from, including the Auto option. |
List work groupslistWorkGroups | POST | Lists available workgroups for the account. |
Update work groupupdateWorkGroup | POST | Updates the workgroup with the specified name. |