[JAVA] Sind Sie immer noch erschöpft von der Beispielvideosuche? Eine Schaltfläche zum Senden von FANZA-Videos an Slack, wenn diese gedrückt wird.

Überblick

• Wenn Sie auf die Schaltfläche AWS IoT Enterprise klicken, erhalten Sie die URL des Beispielvideos von der FANZA-API und senden es nach dem Zufallsprinzip an Slack. Notieren Sie sich daher die technischen Details als Memorandum.

Zweck

• Ich habe AWS IoT bei Nori gekauft, versuchen Sie es also.
• Ich möchte die Zeit für die Suche nach Beispielvideos mehrmals pro Woche verkürzen.
• Ich wollte AWS Lambda lokal entwickeln.
• Ich wollte Kotlin schreiben.

Ziel

• Personen, die AWS Lambda verwenden möchten
• Leute, die AWS Lambda entwickeln wollen, während sie lokal debuggen
• Personen, die eine Nachricht aus dem Programm an Slack senden möchten
• Personen, die die Schaltfläche "AWS IoT" verwenden möchten
• Leute, die "AWS Lambda" in "Java" schreiben wollen
• Leute, die "AWS Lambda" mit "Kotlin" schreiben wollen
• Personen, die durch die Suche nach Beispielvideos erschöpft sind

Eine solche.

Annahmen (Umwelt usw.)

• macOS : macOS Mojave 10.14.5
• Sie haben den "AWS IoT Enterprise Button" gekauft.
• IntelliJ IDEA ultimate
• Docker installiert (für die lokale Entwicklung erforderlich)
• FANZA API kann getroffen werden (DMM-Partner-ID-Erfassung → FANZA API-ID-Erfassung)

Quellcode

https://github.com/yu-suke-dev/fanza-bot

Ein Projekt erstellen

Plug-In installieren

• Installieren Sie das Plugin AWS ToolKit.

Starten Sie das Projekt

• Wählen Sie "AWS Setverless Application", um das Projekt zu starten.

Die Projekthierarchie sieht folgendermaßen aus:

[sample]
   ├── HelloWorldFunction
   │   ├── build.gradle
   │   ├── gradle
   │   │   └── wrapper
   │   │       ├── gradle-wrapper.jar
   │   │       └── gradle-wrapper.properties
   │   ├── gradlew
   │   ├── gradlew.bat
   │   └── src
   │       ├── main
   │       │   └── java
   │       │       └── helloworld
   │       │           ├── App.java
   │       │           └── GatewayResponse.java
   │       └── test
   │           └── java
   │               └── helloworld
   │                   └── AppTest.java
   ├── README.md
   ├── sample.iml
   └── template.yaml

Durch Kotlin ersetzen.

• build.gradle

build.gradle

plugins {
    id 'org.jetbrains.kotlin.jvm' version '1.3.40'
}

apply plugin: 'kotlin'

repositories {
    mavenCentral()
}

sourceCompatibility = '1.8'
targetCompatibility = '1.8'

jar {
    manifest {
        attributes('Main-Class': 'fanza.App')
    }
    from { configurations.compile.collect { it.isDirectory() ? it : zipTree(it) } }
}

dependencies {
    compile "com.amazonaws:aws-lambda-java-core:1.2.0"
    compile "org.jetbrains.kotlin:kotlin-stdlib-jdk8:1.3.40"
    compile "com.squareup.okhttp3:okhttp:3.9.0"
    compile "org.json:json:20180813"
    testCompile "junit:junit:4.12"
}

• src Gehen Sie wie folgt vor:

[src]
  ├── main
  │   └── kotlin
  │       └── fanza
  │           └── App.java
  └── test
  │   └── java
  │       └── fanza
  │           └── AppTest.java

• App.kt

App.kt

package fanza

import com.amazonaws.services.lambda.runtime.Context
import com.amazonaws.services.lambda.runtime.RequestHandler
import okhttp3.MediaType
import okhttp3.OkHttpClient
import okhttp3.Request
import okhttp3.RequestBody
import org.json.JSONObject
import java.io.IOException

/**
 * Handler for requests to Lambda function.
 */
class App : RequestHandler<Any, Any> {

    /**
     * called method
     */
    override fun handleRequest(input: Any, context: Context): Any {

        try {
            //ID für Fanza-API erforderlich
            var fanzaApiId = System.getenv("FANZA_API_ID")
            var affiliateId = System.getenv("FANZA_AFFILIATE_ID")

            //Erstellen Sie die URL, nach der Sie suchen möchten
            val fanzaUrl: String = "https://api.dmm.com/affiliate/v3/ItemList"
                    .plus("?api_id=$fanzaApiId")
                    .plus("&affiliate_id=$affiliateId")
                    .plus("&site=FANZA&service=digital&floor=videoa")
                    .plus("&hits=20&sort=date&keyword=Amateur&output=json")

            //GET nach FANZA
            val fanzaInfo = get(fanzaUrl).replace("\\", "")

            //Regulärer Ausdruck des Teils, den Sie extrahieren möchten
            val regex = Regex("https://www.dmm.co.jp/litevideo/-/part/=/cid=[a-z]{3,5}[0-9]{3,5}/size=720_480/")

            //Extrahieren Sie zufällig eine aus den extrahierten Ergebnissen
            val result: String = regex.findAll(fanzaInfo)
                    .map { it.value }
                    .toList()
                    .random()

            //Slack Webhook URL
            var slackUrl: String = System.getenv("SLACK_URL")

            //Was soll ich an Slack senden?
            var slackJson = JSONObject()
            slackJson.put("channel", "#fanza")
            slackJson.put("username", "fanza-bot")
            slackJson.put("text", result)
            slackJson.put("icon_emoji", ":womens:")

            //post senden
            post(slackUrl, slackJson.toString())

            return "Success"

        } catch (e: IOException) {
            return RuntimeException(e)
        }
    }

    /**
     * get
     */
    @Throws(IOException::class)
    operator fun get(url: String): String {
        val request = Request.Builder()
                .url(url)
                .header("Content-Type", "application/json")
                .addHeader("X-Custom-Header", "application/json")
                .build()
        val client = OkHttpClient.Builder().build()
        val response = client.newCall(request).execute()
        return response.body()!!.string()
    }

    /**
     * post
     */
    @Throws(IOException::class)
    fun post(url: String, json: String): String {
        val body = RequestBody
                .create(MediaType.parse("application/json; charset=utf-8"), json)
        val request = Request.Builder()
                .url(url)
                .put(body)
                .build()
        val client = OkHttpClient()
        return client.newCall(request).execute().body()!!.string()
    }
}

Umgebungsvariablen einstellen

Funktionsprüfung

Ausführungsergebnis

• Wenn Slack eine erfolgreiche Benachrichtigung erhält und die Konsole Folgendes anzeigt, ist dies erfolgreich.

Jar-Datei erstellen

• Wenn Sie fertig sind, erstellen Sie eine Jar-Datei.

gradle jar

Auf Lambda hochladen

• Umgebungsvariable: Stellen Sie die gleiche wie die lokal festgelegte ein.
• Laden Sie die oben erstellte Jar-Datei hoch.

Verknüpfung von AWS IoT Button und AWS Lambda

• Produkt registrieren: Ausgelassen. Registrieren Sie das Produkt anhand der folgenden Artikel. 　https://qiita.com/shogo_m/items/9aa7b400a031e8503e7f

• Projekt erstellen: Wählen Sie im AWS-Konsolenbildschirm "IoT 1-Click" aus

• Angabe des Projektnamens

• Geben Sie hier die erstellte Lambda-Funktion an.

Ausführungsergebnis

Drücken Sie den Knopf. (Pochi)

• Überprüfen Sie das Ausführungsergebnis in Slack.

Zusammenfassung

• Dieses Mal habe ich nur die Operation mit einem Klick versucht.
• Das Abrufen der Slack Webhook-URL entfällt.
• Versuchen Sie für Java, es durch Java zu ersetzen.
• Dieses Mal habe ich die Umgebungsvariable in Lambda festgelegt, aber es ist sicherer, sie in AWS KMS festzulegen.
• Der Testcode, die Protokolle usw. sind schlecht, daher würde ich sie gerne umgestalten, wenn ich Zeit habe.

Referenzierter Artikel (Danke)

• https://qiita.com/naokiur/items/548fc01240c2488de15c
• https://qiita.com/shogo_m/items/9aa7b400a031e8503e7f