Skip to content

Instantly share code, notes, and snippets.

functions:
create:
handler: todos/create.create
events:
- http:
path: todos
method: post
cors: true
list:
# Update order file on s3 once order is fulfilled
def lambda_mark_order_fulfilled(event, context):
# Copy inputs into variables
bucket = event['Records'][0]['s3']['bucket']['name']
key = event['Records'][0]['s3']['object']['key']
order = key.split("/")[3]
s3 = boto3.client('s3')
# download file to /tmp
download_path = '/tmp/' + order;
s3.download_file(bucket, key, download_path)
@shar1z
shar1z / airflow.py
Last active February 26, 2020 15:17
airflow-import-test
#!/usr/bin/env python
from airflow.models import DagBag
import sys,os
if len(sys.argv) == 1:
print "Dag folder needs to be provided as a parameter"
sys.exit(2)
print "==== Testing DAG loading ===="
db = DagBag(sys.argv[1])
if len(db.import_errors) > 0:
print "There have been import errors, the following dag files are broken:"
@shar1z
shar1z / html.html
Created May 8, 2019 08:45
Html Sample file
<!DOCTYPE html>
<html lang="en">
<head>
<meta charset="UTF-8">
<title>Hello Rust 👋</title>
<script src="hello.js"></script>
</head>
<body>
</body>
</html>
@shar1z
shar1z / ex2.rs
Created May 8, 2019 08:44
Rust Example file
fn main() {
let greetings = ["Hello", "Hola", "Bonjour",
"Ciao", "こんにちは", "안녕하세요",
"Cześć", "Olá", "Здравствуйте",
"Chào bạn", "您好", "Hallo",
"Hej", "Ahoj", "سلام","สวัสดี"];
for (num, greeting) in greetings.iter().enumerate() {
print!("{} : ", greeting);
match num {
0 => println!("This code is editable and runnable!"),
@shar1z
shar1z / ex.rs
Created May 8, 2019 08:41
ex.rs
#[no_mangle]
pub extern "C" fn add_one(x: i32) -> i32 {
x + 1
}
@shar1z
shar1z / ex.WAT
Created May 8, 2019 08:40
ex.WAT
(module
(type $t0 (func (param i32) (result i32)))
(func $add_one (export "add_one") (type $t0) (param $p0 i32) (result i32)
get_local $p0
i32.const 1
i32.add)
(table $T0 1 1 anyfunc)
@shar1z
shar1z / custom_ui.js
Created April 1, 2019 12:05
custom_ui.js
@Override
public void hear(final Event event) {
ExtensionErrorCallback<ExtensionError> errorCallback = new ExtensionErrorCallback<ExtensionError>() {
@Override
public void error(final ExtensionError extensionError) {
Log.e(AFEXTENSION, "error receiving sharedState event: "+ extensionError.getErrorName());
}
};
Map<String, Object> eventData = event.getEventData();
@shar1z
shar1z / salting3.scala
Last active February 21, 2019 17:33
salting3.scala
val unSaltedWindow = Window
.partitionBy($"client_id") // Note -- no salt
.orderBy($"install_count".desc)
val unSaltedResult = saltedResult
.withColumn("row_num", row_number().over(unSaltedWindow))
.filter($"row_num" <= 1000)
@shar1z
shar1z / salting2.scala
Last active February 21, 2019 17:34
salting2.scala
val saltedWindow = Window
.partitionBy($"client_id",$"salt")
.orderBy($"install_count".desc)
val saltedResult = dataWithSalt
.withColumn("row_num", row_number().over(saltedWindow))
.filter($"row_num" <= 1000)