Skip to content
This repository has been archived by the owner on Jul 1, 2024. It is now read-only.

Commit

Permalink
Update snippets to match the checked-in/tested code (#4245)
Browse files Browse the repository at this point in the history
  • Loading branch information
@cnunciato
cnunciato authored May 2, 2024
1 parent ac100a3 commit 5395f18
Showing 1 changed file with 65 additions and 59 deletions.
124 changes: 65 additions & 59 deletions themes/default/content/blog/next-level-iac-pulumi-runtime-logic/index.md
View file
Original file line number Diff line number Diff line change
Expand Up @@ -61,22 +61,25 @@ import * as aws from "@pulumi/aws";
import * as childProcess from "child_process";

// Build the website.
const proc = childProcess.execSync("hugo", { stdio: "inherit", cwd: "./www" });
const result = childProcess.execSync("hugo --destination ./public", { stdio: "pipe", cwd: "./www" });

// Provision a storage bucket for the website.
const bucket = new aws.s3.Bucket("bucket", {
website: {
indexDocument: "index.html"
indexDocument: "index.html",
},
});

// Copy the website home page into the bucket.
const homepage = new aws.s3.BucketObject("index.html", {
bucket: bucket.id,
content: fs.readFileSync("./www/public/index.html", "utf-8"),
contentType: "text/html",
acl: "public-read",
});
const homepage = new aws.s3.BucketObject(
"index.html",
{
bucket: bucket.id,
content: fs.readFileSync("./www/public/index.html", "utf-8"),
contentType: "text/html",
acl: "public-read",
},
);
```

{{% /choosable %}}
Expand All @@ -88,15 +91,27 @@ import pulumi_aws as aws
import subprocess

# Build the website.
result = subprocess.run(["hugo", "--destination", "./public"], stdout=subprocess.PIPE, cwd="./www", check=True, shell=True)

# Log the build output to the console.
print(result.stdout.decode())
result = subprocess.run(
["hugo", "--destination", "./public"],
stdout=subprocess.PIPE,
cwd="./www",
check=True,
shell=True,
)

# Provision a storage bucket for the website.
bucket = aws.s3.Bucket("bucket", website=aws.s3.BucketWebsiteArgs(
index_document="index.html"
))
bucket = aws.s3.Bucket(
"bucket", website=aws.s3.BucketWebsiteArgs(index_document="index.html")
)

# Copy the website home page into the bucket
homepage = aws.s3.BucketObject(
"index.html",
bucket=bucket.id,
content=open("./www/public/index.html", "r").read(),
content_type="text/html",
acl="public-read",
)
```

{{% /choosable %}}
Expand Down Expand Up @@ -150,20 +165,24 @@ Again, a totally reasonable approach. But again, why bother, when you have the f
```typescript
// ...

// Fetch some redirects from a hypothetical CMS, pulling its URL from the environment.
// Fetch some redirects from a hypothetical CMS.
const redirects = fetch(`${process.env.CMS_ENDPOINT}/redirects.json`)
.then(response => response.json())
.then(items => items.forEach((redirect: any, i: number) => {

// Create an S3 website redirect for each one.
new aws.s3.BucketObject(`redirect-${i}`, {
bucket: bucket.id,
key: redirect.from,
websiteRedirect: redirect.to,
acl: "public-read",
});
}),
);
.then(items =>
items.forEach((redirect: any, i: number) => {
// Create an S3 website redirect for each one.
new aws.s3.BucketObject(
`redirect-${i}`,
{
bucket: bucket.id,
key: redirect.from,
websiteRedirect: redirect.to,
acl: "public-read",
},
{ dependsOn: [ownershipControls, publicAccess] },
);
}),
);
```

{{% /choosable %}}
Expand All @@ -184,7 +203,8 @@ redirects = json.loads(response.text)

# Create an S3 website redirect for each one.
for i, redirect in enumerate(redirects):
aws.s3.BucketObject(f"redirect-{i}",
aws.s3.BucketObject(
f"redirect-{i}",
bucket=bucket.id,
key=redirect["from"],
website_redirect=redirect["to"],
Expand Down Expand Up @@ -233,29 +253,28 @@ const cdn = new aws.cloudfront.Distribution("cdn", {
// ...
});

// Register a function to be invoked before the program exits.
process.on("beforeExit", () => {

function createInvalidation(id: string) {
// Only invalidate after a deployment.
if (pulumi.runtime.isDryRun()) {
console.log("This is a Pulumi preview, so skipping cache invalidation.");
return;
}

cdn.id.apply(id => {
process.on("beforeExit", () => {
const client = new cloudfront.CloudFrontClient({ region });
const command = new cloudfront.CreateInvalidationCommand({
DistributionId: id,
InvalidationBatch: {
CallerReference: `invalidation-${Date.now()}`,
Paths: {
Quantity: 1,
Items: [ "/*" ],
Items: ["/*"],
},
},
});

client.send(command)
client
.send(command)
.then(result => {
console.log(`Invalidation status for ${id}: ${result.Invalidation?.Status}.`);
process.exit(0);
Expand All @@ -265,7 +284,10 @@ process.on("beforeExit", () => {
process.exit(1);
});
});
});
}

// Register a function to be invoked before the program exits.
cdn.id.apply(id => createInvalidation(id));
```

The relevant code is the call to [`process.on("beforeExit")`](https://nodejs.org/api/process.html#event-beforeexit), which registers a function to be invoked just before the program exits using the resolved ID of the distribution. (For more on how the `apply()` method works, see [Inputs and Outputs](https://www.pulumi.com/docs/concepts/inputs-outputs/).) The function returns early for Pulumi previews --- no sense clearing the cache if the site hasn't changed --- and uses the [AWS SDK for JavaScript](https://aws.amazon.com/sdk-for-javascript/) to submit the invalidation request to CloudFront, naming it uniquely with a timestamp and logging the result to the console:
Expand All @@ -279,22 +301,7 @@ The relevant code is the call to [`process.on("beforeExit")`](https://nodejs.org
import boto3
import asyncio

# Create a CloudFront distribution for the website.
cdn = aws.cloudfront.Distribution("cdn",
enabled=True,
default_root_object="index.html",
origins=[
aws.cloudfront.DistributionOriginArgs(
origin_id=bucket.arn,
domain_name=bucket.website_endpoint,
# ...
)
],
#...
)

def create_invalidation(id):

# Don't bother invalidating unless it's an actual deployment.
if pulumi.runtime.is_dry_run():
print("This is a Pulumi preview, so skipping cache invalidation.")
Expand All @@ -304,25 +311,24 @@ def create_invalidation(id):
result = client.create_invalidation(
DistributionId=id,
InvalidationBatch={
"CallerReference": f"invalidation-{str(time.time)}",
"CallerReference": f"invalidation-{time.time()}",
"Paths": {
"Quantity": 1,
"Items": [ "/*" ],
"Items": ["/*"],
},
},
)

print(f"Cache invalidation of distribution {id}: {result['Invalidation']['Status']}.")
print(
f"Cache invalidation for distribution {id}: {result['Invalidation']['Status']}."
)

# Register a function to be invoked before the program exits.
async def invalidate(id):
await asyncio.to_thread(create_invalidation, id)

# Wait for the distribution ID to become available.
cdn.id.apply(lambda id: invalidate(id))
# Register a function to be invoked before the program exits.
cdn.id.apply(lambda id: atexit.register(lambda: create_invalidation(id)))
```

The relevant code is the call to [`asyncio.to_thread()`](https://docs.python.org/3/library/asyncio-task.html#running-in-threads), which registers a function to be invoked just before the program exits using the resolved ID of the distribution. (For more on how the `apply()` method works, see [Inputs and Outputs](https://www.pulumi.com/docs/concepts/inputs-outputs/).) The function returns early for Pulumi previews --- no sense clearing the cache if the site hasn't changed --- and uses [Boto3](https://boto3.amazonaws.com/v1/documentation/api/latest/index.html) to submit the invalidation request to CloudFront, naming it uniquely with a timestamp and logging the result to the console:
The relevant code is the call to [`atexit.register()`](https://docs.python.org/3/library/atexit.html), which registers a function to be invoked just before the program exits using the resolved ID of the distribution. (For more on how the `apply()` method works, see [Inputs and Outputs](https://www.pulumi.com/docs/concepts/inputs-outputs/).) The function returns early for Pulumi previews --- no sense clearing the cache if the site hasn't changed --- and uses [Boto3](https://boto3.amazonaws.com/v1/documentation/api/latest/index.html) to submit the invalidation request to CloudFront, naming it uniquely with a timestamp and logging the result to the console:

{{% /choosable %}}

Expand Down

0 comments on commit 5395f18

Please sign in to comment.