MORPH
SIGN IN SIGN UP
awsdocs / aws-doc-sdk-examples UNCLAIMED

Welcome to the AWS Code Examples Repository. This repo contains code examples used in the AWS documentation, AWS SDK Developer Guides, and more. For more information, see the Readme.md file below.

0 0 1 Java
Normal View History Raw
PHP Glue MVP initial commit.
2022-09-09 14:13:09 -07:00
<?php
Added copyright.
2022-09-13 09:02:09 -07:00
// Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
// SPDX-License-Identifier: Apache-2.0
Adds missing scenario tags for PHP Glue.
2022-09-09 15:40:46 -07:00
#snippet-start:[php.example_code.glue.service]
PHP Glue MVP initial commit.
2022-09-09 14:13:09 -07:00
namespace Glue;
use Aws\Glue\GlueClient;
use Aws\Result;
use function PHPUnit\Framework\isEmpty;
class GlueService extends \AwsUtilities\AWSServiceClass
{
protected GlueClient $glueClient;
public function __construct($glueClient)
{
$this->glueClient = $glueClient;
}
#snippet-start:[php.example_code.glue.service.getCrawler]
public function getCrawler($crawlerName)
{
return $this->customWaiter(function () use ($crawlerName) {
return $this->glueClient->getCrawler([
'Name' => $crawlerName,
]);
});
}
#snippet-end:[php.example_code.glue.service.getCrawler]
#snippet-start:[php.example_code.glue.service.createCrawler]
public function createCrawler($crawlerName, $role, $databaseName, $path): Result
{
return $this->customWaiter(function () use ($crawlerName, $role, $databaseName, $path) {
return $this->glueClient->createCrawler([
'Name' => $crawlerName,
'Role' => $role,
'DatabaseName' => $databaseName,
'Targets' => [
'S3Targets' =>
[[
'Path' => $path,
]]
],
]);
});
}
#snippet-end:[php.example_code.glue.service.createCrawler]
#snippet-start:[php.example_code.glue.service.startCrawler]
public function startCrawler($crawlerName): Result
{
return $this->glueClient->startCrawler([
'Name' => $crawlerName,
]);
}
#snippet-end:[php.example_code.glue.service.startCrawler]
#snippet-start:[php.example_code.glue.service.getDatabase]
public function getDatabase(string $databaseName): Result
{
return $this->customWaiter(function () use ($databaseName) {
return $this->glueClient->getDatabase([
'Name' => $databaseName,
]);
});
}
#snippet-end:[php.example_code.glue.service.getDatabase]
#snippet-start:[php.example_code.glue.service.getTables]
public function getTables($databaseName): Result
{
return $this->glueClient->getTables([
'DatabaseName' => $databaseName,
]);
}
#snippet-end:[php.example_code.glue.service.getTables]
#snippet-start:[php.example_code.glue.service.createJob]
public function createJob($jobName, $role, $scriptLocation, $pythonVersion = '3', $glueVersion = '3.0'): Result
{
return $this->glueClient->createJob([
'Name' => $jobName,
'Role' => $role,
'Command' => [
'Name' => 'glueetl',
'ScriptLocation' => $scriptLocation,
'PythonVersion' => $pythonVersion,
],
'GlueVersion' => $glueVersion,
]);
}
#snippet-end:[php.example_code.glue.service.createJob]
#snippet-start:[php.example_code.glue.service.startJobRun]
public function startJobRun($jobName, $databaseName, $tables, $outputBucketUrl): Result
{
return $this->glueClient->startJobRun([
'JobName' => $jobName,
'Arguments' => [
'input_database' => $databaseName,
'input_table' => $tables['TableList'][0]['Name'],
'output_bucket_url' => $outputBucketUrl,
'--input_database' => $databaseName,
'--input_table' => $tables['TableList'][0]['Name'],
'--output_bucket_url' => $outputBucketUrl,
],
]);
}
#snippet-end:[php.example_code.glue.service.startJobRun]
#snippet-start:[php.example_code.glue.service.listJobs]
public function listJobs($maxResults = null, $nextToken = null, $tags = []): Result
{
$arguments = [];
if ($maxResults) {
$arguments['MaxResults'] = $maxResults;
}
if ($nextToken) {
$arguments['NextToken'] = $nextToken;
}
Php docker (#4384) * Adjusts docker container for php. Also fixes some problems with pathing and tests for extant php tests to better work with docker.
2023-02-14 16:31:03 -07:00
if (!empty($tags)) {
PHP Glue MVP initial commit.
2022-09-09 14:13:09 -07:00
$arguments['Tags'] = $tags;
}
return $this->glueClient->listJobs($arguments);
}
#snippet-end:[php.example_code.glue.service.listJobs]
#snippet-start:[php.example_code.glue.service.getJobRuns]
public function getJobRuns($jobName, $maxResults = 0, $nextToken = ''): Result
{
$arguments = ['JobName' => $jobName];
if ($maxResults) {
$arguments['MaxResults'] = $maxResults;
}
if ($nextToken) {
$arguments['NextToken'] = $nextToken;
}
return $this->glueClient->getJobRuns($arguments);
}
#snippet-end:[php.example_code.glue.service.getJobRuns]
#snippet-start:[php.example_code.glue.service.getJobRun]
public function getJobRun($jobName, $runId, $predecessorsIncluded = false): Result
{
return $this->glueClient->getJobRun([
'JobName' => $jobName,
'RunId' => $runId,
'PredecessorsIncluded' => $predecessorsIncluded,
]);
}
#snippet-end:[php.example_code.glue.service.getJobRun]
#snippet-start:[php.example_code.glue.service.deleteJob]
public function deleteJob($jobName)
{
return $this->glueClient->deleteJob([
'JobName' => $jobName,
]);
}
#snippet-end:[php.example_code.glue.service.deleteJob]
#snippet-start:[php.example_code.glue.service.deleteTable]
public function deleteTable($tableName, $databaseName)
{
return $this->glueClient->deleteTable([
'DatabaseName' => $databaseName,
'Name' => $tableName,
]);
}
#snippet-end:[php.example_code.glue.service.deleteTable]
#snippet-start:[php.example_code.glue.service.deleteDatabase]
public function deleteDatabase($databaseName)
{
return $this->glueClient->deleteDatabase([
'Name' => $databaseName,
]);
}
#snippet-end:[php.example_code.glue.service.deleteDatabase]
#snippet-start:[php.example_code.glue.service.deleteCrawler]
public function deleteCrawler($crawlerName)
{
return $this->glueClient->deleteCrawler([
'Name' => $crawlerName,
]);
}
#snippet-end:[php.example_code.glue.service.deleteCrawler]
}
Adds missing scenario tags for PHP Glue.
2022-09-09 15:40:46 -07:00
#snippet-end:[php.example_code.glue.service]
Reference in New Issue Copy Permalink