laughingman7743

#!/usr/bin/env python
# -*- coding: utf-8 -*-
from __future__ import print_function
from __future__ import unicode_literals
from __future__ import division

import re
import signal
import sys
import time

laughingman7743

#!/usr/bin/env python
# -*- coding: utf-8 -*-
from __future__ import print_function

import json

import requests

SLACK_API = 'https://slack.com/api/'
SLACK_API_METHOD = 'chat.postMessage'

laughingman7743

{
  "Records": [
    {
      "eventID": "shardId-000000000000:49545115243490985018280067714973144582180062593244200961",
      "eventVersion": "1.0",
      "kinesis": {
        "partitionKey": "partitionKey-3",
        "data": "SGVsbG8sIHRoaXMgaXMgYSB0ZXN0IDEyMy4=",
        "kinesisSchemaVersion": "1.0",
        "sequenceNumber": "49545115243490985018280067714973144582180062593244200961"

laughingman7743

#!/usr/bin/env python
# -*- coding: utf-8 -*-
"""
analyze-vacuum-schema.py
* Copyright 2015, Amazon.com, Inc. or its affiliates. All Rights Reserved.
*
* Licensed under the Amazon Software License (the "License").
* You may not use this file except in compliance with the License.
* A copy of the License is located at
*

laughingman7743

#!/usr/bin/env python
# -*- coding: utf-8 -*-
import boto3


SCRIPT_RUNNER_JAR = 's3://us-east-1.elasticmapreduce/libs/script-runner/script-runner.jar'
BASE_ARGS_HIVE_STEP = [
    '/usr/share/aws/emr/scripts/hive-script',
    '--run-hive-script',
    '--args',

laughingman7743

[program:airflow-scheduler]
process_name=%(program_name)s
directory=/home/airflow
environment=PATH="/usr/local/bin:/bin:/usr/bin:/usr/local/sbin:/usr/sbin:/sbin:$PATH",AIRFLOW_HOME=/home/airflow/airflow
command=/usr/local/bin/airflow scheduler
autostart=true
autorestart=true
user=airflow
redirect_stderr=true
stdout_logfile=/var/log/airflow/%(program_name)s.log

laughingman7743

#!/usr/bin/env python
# -*- coding: utf-8 -*-
"""
brew install yajl

Requirements:
  pip install elasticsearch
  pip install geojson
  pip install ijson
  pip install simplejson

laughingman7743

name := """play24-add-universal"""

version := "1.0-SNAPSHOT"

lazy val root = (project in file(".")).enablePlugins(PlayScala)

scalaVersion := "2.11.6"

libraryDependencies ++= Seq(
  jdbc,

laughingman7743

test attachment

laughingman7743

# Database configuration
# ~~~~~
# You can declare as many datasources as you want.
# By convention, the default datasource is named `default`
#
slick.dbs.default.driver="slick.driver.PostgresDriver$"
slick.dbs.default.db.driver=org.postgresql.Driver
slick.dbs.default.db.url="jdbc:postgresql://localhost:5432/YOUR_DATABASE"
slick.dbs.default.db.username=YOUR_USER
slick.dbs.default.db.password="YOUR_PASSWORD"