growing hard days.

Rocket.ChatにAWS Lambda(Python)から投稿する

2020/06/17 2020/06/17

Rocket.ChatにAPIで投稿するテスト(Postman)をやってみて、使い方がわかってきましたので、AWS Lambda PythonでRocket.Chatに投稿してみます。

import logging
import json
import traceback
import os
import requests

logger = logging.getLogger()
logger.setLevel(logging.DEBUG)

token = os.environ.get('rocket_token', None)
user_id = os.environ.get('rocket_user_id', None)
room_id = os.environ.get('rocket_room_id', None)
url = os.environ.get('rocket_url', None)


def lambda_handler(event, context):
    logger.debug(event)
    try:
        headers = {
            'X-Auth-Token': token,
            'X-User-Id': user_id,
            'Content-Type': 'application/json'
        }

        for record in event['Records']:
            message = json.loads(record['Message'])

            project_id = message['project_id']
            description = message['detail']

            message = {
                'message': {
                    'rid': room_id,
                    'msg': description
                }
            }

            response = requests.post(
                url,
                data=json.dumps(message),
                headers=headers
            )

            logger.debug(response.text)
    except:
        logger.error(traceback.format_exc())

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

41

42

43

44

45

46

47

48

import logging

import json

import traceback

import os

import requests

logger = logging.getLogger()

logger.setLevel(logging.DEBUG)

token = os.environ.get('rocket_token', None)

user_id = os.environ.get('rocket_user_id', None)

room_id = os.environ.get('rocket_room_id', None)

url = os.environ.get('rocket_url', None)

def lambda_handler(event, context):

logger.debug(event)

try:

headers = {

'X-Auth-Token': token,

'X-User-Id': user_id,

'Content-Type': 'application/json'

}

for record in event['Records']:

message = json.loads(record['Message'])

project_id = message['project_id']

description = message['detail']

message = {

'message': {

'rid': room_id,

'msg': description

}

}

response = requests.post(

url,

data=json.dumps(message),

headers=headers

)

logger.debug(response.text)

except:

logger.error(traceback.format_exc())

POSTした後のレスポンスでは、メッセージIDとかも返ってくるので、投稿したトピックのレスポンスとかも取得して、いろいろできそうです。

トークンとか環境変数にしています。
そのうち、SecretsManagerにします。

最後までお読みいただきましてありがとうございました！

【PR】「AWS認定試験対策 AWS クラウドプラクティショナー」という本を書きました。

【PR】「AWSではじめるLinux入門ガイド」という本を書きました。

【PR】「ポケットスタディ AWS認定デベロッパーアソシエイト」という本を書きました。

開発ベンダー5年、ユーザ企業システム部門通算9年、ITインストラクター3年目でプロトタイプビルダーもやりだしたSoftware Engineerです。
質問はコメントかSNSなどからお気軽にどうぞ。
出来る限りなるべく答えます。

このブログの内容/発言の一切は個人の見解であり、所属する組織とは関係ありません。
このブログは経験したことなどの共有を目的としており、手順や結果などを保証するものではありません。
ご参考にされる際は、読者様自身のご判断にてご対応をお願いいたします。

また、勉強会やイベントのレポートは自分が気になったことをメモしたり、聞いて思ったことを書いていますので、登壇者の意見や発表内容ではありません。

- AWS AWS, lambda, rocketchat

Tweet

関連記事

: PyCharmにAWS CloudFormationプラグインをインストールして入力補完してみる

JetBrainsのPython統合開発環境(IDE)のPyCharmを1年ちょ …

: webフォームからの問い合わせをRedmineに自動登録して対応状況を管理する(API Gateway + Lambda)

先日、検証目的で作成したRedmineの冗長化の一機能として、webフォームから …

: AlexaにAWSの最新Feedを読み上げてもらう(Lambda Python)

年末にAmazon Echo Dotを購入しましたので、練習がてらAlexaスキ …

: よくあるサーバーレスアーキテクチャで質問フォーム

この記事はServerless2 Advent Calendar 2018に参加 …

: AWS CloudFormationでAmazon DynamoDBテーブルを作ってアイテムを追加する

デモ用にDynamoDBテーブルを作って消して、ということをたまにするので、Cl …

: ヤマムギ vol.10 (AWS)EC2モニタリングハンズオン手順

このブログは2020/5/6に開催しました、「ヤマムギ vol.10 (AWS) …

: Amazon SES(Simple Email Service)でメール受信時のアクションでLambdaを実行して渡されるデータを見てみる

Amazon SESで受信したメールをS3に保存して、S3のトリガーでLambd …

: AWS DataLake 構築ハンズオンに行ってきました

AWSJ大阪が増床されて2019年10月限定でAWS pop-up loftとい …

: Amazon EC2 Auto Scalingのライフサイクルフック

EC2 Auto Scalingにライフサイクルフックという機能があります。ス …

: AWS Client VPNの接続ログを確認しました

AWS Client VPNを設定しましたで証明書とかせっかく作ったので、いろい …

PREV: Rocket.ChatにAPIで投稿するテスト(Postman)
NEXT: Rocket.ChatからOut Going Webhookを設定してみる

NEW POST

: GarageBandでコーラスの録音にTASCAMコンデンサーマイクロホンTM-80を使用した

GarageBandでコーラス録音するマイクに、TASCAMコンデンサーマイクロ …

: AWS KMSのキーポリシーとアイデンティティベースポリシー

AWS KMSのCMKを作成する際に、管理者とキーユーザーを選択することで、以下 …

: GarageBandでのレコーディングにTASCAM オーディオ/MIDIインターフェース iXRを使うときのケーブル

iPad ProとiXRを使っている理由 GarageBand、リモートレコーデ …

: S3バケットポリシーでクロスアカウントのPrincipalについて確認

確認したことドキュメントではこちらで確認しました。 AWS JSON ポリシー …

: VPCピア接続した先のVPCインターフェイスエンドポイントを使用する

VPC1とVPC2でピア接続しています。 VPC2にはKMSのインターフェイスエ …

配信ライブカレンダー

[PR] AWS認定試験対策 AWS クラウドプラクティショナー

[PR] AWSではじめるLinux入門ガイド

[PR] ポケットスタディ AWS認定デベロッパー – アソシエイト

タグ
alexa alexaday2019 api apigateway AWS CentOS cloud9 cloudformation cloudwatch devsumi2018 dynamodb EC2 google iam iot iphone Java jaws jaws-ug kintone lambda Linux m1mac mac mac-mini Markdown mint MySQL organizations PHP python RDS re:dash Redmine remote s3 Silver sns ssm Twilio vpc windows WordPress yamamugi 勉強会

アーカイブ
アーカイブ

AMAZONアソシエイト

「Amazon.co.jpアソシエイト」または「ヤマムギ」は、Amazon.co.jpを宣伝しリンクすることによってサイトが紹介料を獲得できる手段を提供することを目的に設定されたアフィリエイトプログラムである、Amazonアソシエイト・プログラムの参加者です。